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

add async counter2

Browse Source
This commit is contained in:
Abhishek Pandey 2023-10-06 20:43:28 +05:30
parent 12b50f1df2
commit 8bb267882f
1 changed files with 9 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -20,6 +20,7 @@ import (
var Ctr metric.Int64Counter var Ctr metric.Int64Counter
var AsyncCtr metric.Int64ObservableCounter var AsyncCtr metric.Int64ObservableCounter
var token int64
type collector struct { type collector struct {
meter metric.Meter meter metric.Meter
@ -48,11 +49,11 @@ func (rmc *collector) registerCounter() {
Ctr, _ = rmc.meter.Int64Counter(growCounter) Ctr, _ = rmc.meter.Int64Counter(growCounter)
AsyncCtr, _ = rmc.meter.Int64ObservableCounter("async_counter") AsyncCtr, _ = rmc.meter.Int64ObservableCounter("async_counter")
var token int64
cb := func(_ context.Context, o metric.Observer) error { cb := func(_ context.Context, o metric.Observer) error {
token++ logger.Ctx(context.Background()).Infow("Async counter callback")
token += 100
o.ObserveInt64(AsyncCtr, token) o.ObserveInt64(AsyncCtr, token)
return nil return nil
} }
@ -90,16 +91,11 @@ func StartClient(ctx context.Context) *metricSdk.MeterProvider {
res = envResource res = envResource
} }
// Setup trace related exp, err := otlpmetricgrpc.New(
// tp, err := setupTraceProvider(ctx, res) ctx,
// if err != nil { otlpmetricgrpc.WithInsecure(),
// return nil otlpmetricgrpc.WithEndpoint("0.0.0.0:4317"),
// } otlpmetricgrpc.WithDialOption(grpc.WithBlock()))
// otel.SetTracerProvider(tp)
// otel.SetTextMapPropagator(xray.Propagator{}) // Set AWS X-Ray propagator
exp, err := otlpmetricgrpc.New(ctx, otlpmetricgrpc.WithInsecure(), otlpmetricgrpc.WithEndpoint("0.0.0.0:4317"), otlpmetricgrpc.WithDialOption(grpc.WithBlock()))
if err != nil { if err != nil {
log.Fatalf("failed to create new OTLP metric exporter: %v", err) log.Fatalf("failed to create new OTLP metric exporter: %v", err)
} }
@ -113,28 +109,3 @@ func StartClient(ctx context.Context) *metricSdk.MeterProvider {
return meterProvider return meterProvider
} }
// // setupTraceProvider configures a trace exporter and an AWS X-Ray ID Generator.
// func setupTraceProvider(ctx context.Context, res *resource.Resource) (*sdktrace.TracerProvider, error) {
// // INSECURE !! NOT TO BE USED FOR ANYTHING IN PRODUCTION
// // traceExporter, err := otlptracegrpc.New(ctx, otlptracegrpc.WithInsecure())
// // Create and start new OTLP trace exporter
// traceExporter, err := otlptracegrpc.New(ctx, otlptracegrpc.WithInsecure(), otlptracegrpc.WithEndpoint("0.0.0.0:4317"), otlptracegrpc.WithDialOption(grpc.WithBlock()))
// if err != nil {
// log.Fatalf("failed to create new OTLP trace exporter: %v", err)
// }
// if err != nil {
// return nil, err
// }
// idg := xray.NewIDGenerator()
// tp := sdktrace.NewTracerProvider(
// sdktrace.WithSampler(sdktrace.AlwaysSample()),
// sdktrace.WithBatcher(traceExporter),
// sdktrace.WithResource(res),
// sdktrace.WithIDGenerator(idg),
// )
// return tp, nil
// }