Versions in this module Expand all Collapse all v1 v1.2.0 Dec 12, 2019 Changes in this version + func ExtractCtx(message *kafka.Message) (opentracing.SpanContext, error) + func Headers(ctx context.Context, msgHeaders []kafka.Header) []kafka.Header + func New(cfg config.Jaeger) (opentracing.Tracer, io.Closer, error) + func Setup(cfg config.Jaeger) (io.Closer, error) + func StartChildSpan(ctx context.Context, name string) opentracing.Span + func StartSpan(name string) opentracing.Span + func StartSpanFromMessage(name string, msg *kafka.Message) opentracing.Span + type KafkaHeaders []kafka.Header + func (h *KafkaHeaders) ForeachKey(handler func(key, val string) error) error + func (h *KafkaHeaders) Set(key, val string)