From 252ec4f7a7f72908e5b6d16945c3b0abe03b2906 Mon Sep 17 00:00:00 2001 From: Abhishek Pandey Date: Fri, 6 Oct 2023 21:24:57 +0530 Subject: [PATCH] Add cumulative temporality --- src/internal/events/adot_sdk_client.go | 19 ++++++++++++++++++- 1 file changed, 18 insertions(+), 1 deletion(-) diff --git a/src/internal/events/adot_sdk_client.go b/src/internal/events/adot_sdk_client.go index 76d62adc1..4b2bcd3fc 100644 --- a/src/internal/events/adot_sdk_client.go +++ b/src/internal/events/adot_sdk_client.go @@ -95,7 +95,9 @@ func StartClient(ctx context.Context) *metricSdk.MeterProvider { ctx, otlpmetricgrpc.WithInsecure(), otlpmetricgrpc.WithEndpoint("0.0.0.0:4317"), - otlpmetricgrpc.WithDialOption(grpc.WithBlock())) + otlpmetricgrpc.WithDialOption(grpc.WithBlock()), + otlpmetricgrpc.WithTemporalitySelector(metricSdk.DefaultTemporalitySelector), + ) if err != nil { log.Fatalf("failed to create new OTLP metric exporter: %v", err) } @@ -109,3 +111,18 @@ func StartClient(ctx context.Context) *metricSdk.MeterProvider { return meterProvider } + +// func deltaSelector(kind metricSdk.InstrumentKind) metricdata.Temporality { +// switch kind { +// case metricSdk.InstrumentKindCounter, +// metricSdk.InstrumentKindHistogram, +// metricSdk.InstrumentKindObservableGauge, +// metricSdk.InstrumentKindObservableCounter: +// return metricdata.DeltaTemporality +// case metricSdk.InstrumentKindUpDownCounter, +// metricSdk.InstrumentKindObservableUpDownCounter: +// return metricdata.CumulativeTemporality +// } + +// panic("unknown instrument kind") +// }