larryh/corso
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add cumulative temporality

Browse Source
This commit is contained in:
Abhishek Pandey 2023-10-06 21:24:57 +05:30
parent 8bb267882f
commit 252ec4f7a7
1 changed files with 18 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/internal/events/adot_sdk_client.go
View File

@ -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")
// }