diff options
| author |  Daenney <daenney@users.noreply.github.com> | 2023-09-07 13:20:37 +0200 |
|---|---|---|
| committer |  GitHub <noreply@github.com> | 2023-09-07 13:20:37 +0200 |
| commit | 14ef09809942800db57de87fe3963770a56b585b (patch) | |
| tree | 89e95f21145bc7ad5745f77be1d998faa9c09695 /internal/tracing | |
| parent | [bugfix] fix checks for deref the same status descendants / ascendants (#2181) (diff) | |
| download | gotosocial-14ef09809942800db57de87fe3963770a56b585b.tar.xz | |
[feature] Support OTLP HTTP, drop Jaeger (#2184)
* [feature] Add http trace exporter, drop Jaeger
Jaeger supports ingesting traces using the OpenTelemetry gRPC or HTTP
methods. The Jaeger project has deprecated the old jaeger transport.
* Add support for submitting traces over HTTP
* Drop support for the old Jaeger protocol
* Upgrade the trace libraries to v1.17
Fixes: #2176
Fixes: #2179
Diffstat (limited to 'internal/tracing')
| -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) } |