Forward otel tracing to sub requests

filecoin-saturn · Jul 12, 2023 · c40095d · c40095d
1 parent 59d1f68
commit c40095d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/fetcher.go b/fetcher.go
@@ -12,7 +12,9 @@ import (
 	"time"
 
 	"github.com/filecoin-saturn/caboose/tieredhashing"
+	"go.opentelemetry.io/otel"
 	"go.opentelemetry.io/otel/attribute"
+	"go.opentelemetry.io/otel/propagation"
 	"go.opentelemetry.io/otel/trace"
 
 	"github.com/google/uuid"
@@ -261,6 +263,7 @@ func (p *pool) fetchResource(ctx context.Context, from string, resource string,
 
 	//trace
 	req = req.WithContext(httpstat.WithHTTPStat(req.Context(), &result))
+	otel.GetTextMapPropagator().Inject(req.Context(), propagation.HeaderCarrier(req.Header))
 
 	var resp *http.Response
 	saturnCallsTotalMetric.WithLabelValues(resourceType).Add(1)