diff options
Diffstat (limited to 'internal/tracing/tracing.go')
| -rw-r--r-- | internal/tracing/tracing.go | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/internal/tracing/tracing.go b/internal/tracing/tracing.go index 16e5a5eb5..a0b25f487 100644 --- a/internal/tracing/tracing.go +++ b/internal/tracing/tracing.go @@ -29,8 +29,8 @@ import ( "github.com/uptrace/bun/extra/bunotel" "go.opentelemetry.io/otel" "go.opentelemetry.io/otel/attribute" - "go.opentelemetry.io/otel/exporters/jaeger" "go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc" + "go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp" "go.opentelemetry.io/otel/propagation" "go.opentelemetry.io/otel/sdk/resource" "go.opentelemetry.io/otel/sdk/trace" @@ -69,8 +69,14 @@ func Initialize() error { return fmt.Errorf("building tracing exporter: %w", err) } tpo = trace.WithBatcher(exp) - case "jaeger": - exp, err := jaeger.New(jaeger.WithCollectorEndpoint(jaeger.WithEndpoint(config.GetTracingEndpoint()))) + case "http": + opts := []otlptracehttp.Option{ + otlptracehttp.WithEndpoint(config.GetTracingEndpoint()), + } + if insecure { + opts = append(opts, otlptracehttp.WithInsecure()) + } + exp, err := otlptracehttp.New(context.Background(), opts...) if err != nil { return fmt.Errorf("building tracing exporter: %w", err) } |