diff --git a/internal/otel.go b/internal/otel.go index eed14e1..d2b82bd 100644 --- a/internal/otel.go +++ b/internal/otel.go @@ -19,10 +19,6 @@ import ( semconv "go.opentelemetry.io/otel/semconv/v1.26.0" ) -var ( - otelEndpoint = "otel-collector:4317" -) - // setupOTelSDK bootstraps the OpenTelemetry pipeline. // If it does not return an error, make sure to call shutdown for proper cleanup. func setupOTelSDK(ctx context.Context) (func(context.Context) error, error) { @@ -96,11 +92,7 @@ func newPropagator() propagation.TextMapPropagator { } func newTracerProvider(ctx context.Context, resource *resource.Resource) (*trace.TracerProvider, error) { - exp, err := otlptracegrpc.New( - ctx, - otlptracegrpc.WithEndpoint(otelEndpoint), - otlptracegrpc.WithInsecure(), - ) + exp, err := otlptracegrpc.New(ctx) if err != nil { return nil, err } @@ -112,10 +104,7 @@ func newTracerProvider(ctx context.Context, resource *resource.Resource) (*trace } func newMeterProvider(ctx context.Context, resource *resource.Resource) (*metric.MeterProvider, error) { - exp, err := otlpmetricgrpc.New( - ctx, - otlpmetricgrpc.WithInsecure(), - otlpmetricgrpc.WithEndpoint(otelEndpoint)) + exp, err := otlpmetricgrpc.New(ctx) if err != nil { return nil, err } @@ -127,10 +116,7 @@ func newMeterProvider(ctx context.Context, resource *resource.Resource) (*metric } func newLoggerProvider(ctx context.Context, resource *resource.Resource) (*log.LoggerProvider, error) { - logExporter, err := otlploggrpc.New( - ctx, - otlploggrpc.WithInsecure(), - otlploggrpc.WithEndpoint(otelEndpoint)) + logExporter, err := otlploggrpc.New(ctx) if err != nil { return nil, err }