Versions in this module Expand all Collapse all v0 v0.0.1 Mar 23, 2022 Changes in this version + const TraceIDLogKey + func ExtractMQHeader(tracer opentracing.Tracer, msg *clusterSarama.ConsumerMessage) (opentracing.SpanContext, error) + func FromIncomingHeaders(headers []*clusterSarama.RecordHeader) metadata.MD + func Init(defaultSrvName string, cfg config.Configuration, options ...config.Option) (opentracing.Tracer, io.Closer) + func InjectMQHeader(tracer opentracing.Tracer, sm opentracing.SpanContext, ctx context.Context, ...) + func NewOutgoingHeaders(h []sarama.RecordHeader, md metadata.MD) []sarama.RecordHeader + func OpenTracingServerMiddleWare() gin.HandlerFunc + func OpentracingClientInterceptor(ctx context.Context, method string, req, reply interface{}, ...) error + func OpentracingServerInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (resp interface{}, err error) + type TextMapRW struct + func (t TextMapRW) ForeachKey(handler func(key, val string) error) error + func (t TextMapRW) Set(key, val string)
Go to main page