add b3 propagator

Followup to #221
EinStack · May 5, 2024 · 636606d · 636606d
1 parent 602f53e
commit 636606d
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 1 deletion.
diff --git a/go.mod b/go.mod
@@ -19,6 +19,7 @@ require (
 	github.com/stretchr/testify v1.9.0
 	github.com/swaggo/swag v1.16.3
 	go.opentelemetry.io/contrib/exporters/autoexport v0.51.0
+	go.opentelemetry.io/contrib/propagators/b3 v1.26.0
 	go.opentelemetry.io/otel v1.26.0
 	go.opentelemetry.io/otel/sdk v1.26.0
 	go.opentelemetry.io/otel/sdk/metric v1.26.0

diff --git a/go.sum b/go.sum
diff --git a/pkg/telemetry/telemetry.go b/pkg/telemetry/telemetry.go
@@ -4,6 +4,7 @@ import (
 	"context"
 
 	"go.opentelemetry.io/contrib/exporters/autoexport"
+	"go.opentelemetry.io/contrib/propagators/b3"
 	"go.opentelemetry.io/otel"
 	"go.opentelemetry.io/otel/propagation"
 	sdkmetric "go.opentelemetry.io/otel/sdk/metric"
@@ -55,7 +56,8 @@ func NewTelemetry(cfg *Config) (*Telemetry, error) {
 		sdktrace.WithBatcher(spanExporter),
 	)
 	otel.SetTracerProvider(tp)
-	otel.SetTextMapPropagator(propagation.NewCompositeTextMapPropagator(propagation.TraceContext{}, propagation.Baggage{}))
+	otel.SetTextMapPropagator(propagation.NewCompositeTextMapPropagator(propagation.TraceContext{},
+		propagation.Baggage{}, b3.New()))
 
 	metricsReader, err := autoexport.NewMetricReader(context.Background())
 	if err != nil {