fix: load telemetry for cli

goto · Sep 12, 2024 · 97c2816 · 97c2816
1 parent 212cf5c
commit 97c2816
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/internal/server/server.go b/internal/server/server.go
@@ -138,15 +138,15 @@ func RunServer(config *Config) error {
 
 	grpcServer := grpc.NewServer(
 		grpc.StreamInterceptor(grpc_middleware.ChainStreamServer(
-			otelgrpc.StreamServerInterceptor(),
 			grpc_logrus.StreamServerInterceptor(logrusEntry),
+			otelgrpc.StreamServerInterceptor(),
 		)),
 		grpc.UnaryInterceptor(grpc_middleware.ChainUnaryServer(
+			authInterceptor,
 			grpc_logrus.UnaryServerInterceptor(logrusEntry),
+			enrichLogrusFields(),
 			otelgrpc.UnaryServerInterceptor(),
 			nrgrpc.UnaryServerInterceptor(nrApp),
-			authInterceptor,
-			enrichLogrusFields(),
 			grpc_recovery.UnaryServerInterceptor(
 				grpc_recovery.WithRecoveryHandler(func(p interface{}) (err error) {
 					logger.Error(context.Background(), string(debug.Stack()))

diff --git a/pkg/opentelemetry/init.go b/pkg/opentelemetry/init.go
@@ -118,7 +118,7 @@ func initGlobalTracer(ctx context.Context, res *resource.Resource, cfg Config) (
 	tracerProvider := sdktrace.NewTracerProvider(
 		sdktrace.WithSampler(sdktrace.AlwaysSample()),
 		sdktrace.WithResource(res),
-		sdktrace.WithSpanProcessor(sdktrace.NewBatchSpanProcessor(exporter)),
+		sdktrace.WithBatcher(exporter),
 	)
 
 	otel.SetTracerProvider(tracerProvider)