log and trace fixes

Signed-off-by: Jörn Friedrich Dreyer <jfd@butonic.de>
2024-04-26 17:03:49 +02:00
parent dadc78d4ff
commit e41472234f
16 changed files with 38 additions and 31 deletions
@@ -56,23 +56,24 @@ func ListenForEvents(ctx context.Context, cfg *config.Config, l log.Logger) erro
 		return err
 	}

+	traceProvider, err := tracing.GetServiceTraceProvider(cfg.Tracing, cfg.Service.Name)
+	if err != nil {
+		l.Error().Err(err).Msg("cannot initialize tracing")
+		return err
+	}
+
 	gatewaySelector, err := pool.GatewaySelector(
 		cfg.Reva.Address,
 		pool.WithTLSCACert(cfg.GRPCClientTLS.CACert),
 		pool.WithTLSMode(tm),
 		pool.WithRegistry(registry.GetRegistry()),
+		pool.WithTracerProvider(traceProvider),
 	)
 	if err != nil {
 		l.Error().Err(err).Msg("cannot get gateway selector")
 		return err
 	}

-	traceProvider, err := tracing.GetServiceTraceProvider(cfg.Tracing, cfg.Service.Name)
-	if err != nil {
-		l.Error().Err(err).Msg("cannot initialize tracing")
-		return err
-	}
-
 	grpcClient, err := grpc.NewClient(
 		append(
 			grpc.GetClientOptions(cfg.GRPCClientTLS),