Put HTTP headers into context in Jaeger Thrift receiver

Signed-off-by: Pavol Loffay <[email protected]>

receiver/jaegerreceiver/trace_receiver.go

@@ -43,6 +43,7 @@ import (
 	"github.com/uber/jaeger-lib/metrics"
 	"go.uber.org/zap"
 	"google.golang.org/grpc"
+	"google.golang.org/grpc/metadata"
 
 	"go.opentelemetry.io/collector/client"
 	"go.opentelemetry.io/collector/component"
@@ -434,6 +435,8 @@ func (jr *jReceiver) HandleThriftHTTPBatch(w http.ResponseWriter, r *http.Reques
 	if c, ok := client.FromHTTP(r); ok {
 		ctx = client.NewContext(ctx, c)
 	}
+	md := toMetadata(r.Header)
+	ctx = metadata.NewIncomingContext(ctx, md)
 
 	ctx = obsreport.ReceiverContext(ctx, jr.instanceName, collectorHTTPTransport)
 	ctx = obsreport.StartTraceDataReceiveOp(ctx, jr.instanceName, collectorHTTPTransport)
@@ -454,6 +457,14 @@ func (jr *jReceiver) HandleThriftHTTPBatch(w http.ResponseWriter, r *http.Reques
 	obsreport.EndTraceDataReceiveOp(ctx, thriftFormat, numSpans, err)
 }
 
+func toMetadata(header http.Header) metadata.MD {
+	md := metadata.MD{}
+	for k, v := range header {
+		md.Append(k, v...)
+	}
+	return md
+}
+
 func (jr *jReceiver) startCollector(host component.Host) error {
 	if !jr.collectorGRPCEnabled() && !jr.collectorHTTPEnabled() {
 		return nil