tracer

Documentation

Index

• 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
  • func (h *KafkaHeaders) ForeachKey(handler func(key, val string) error) error
  • func (h *KafkaHeaders) Set(key, val string)

Functions

func ExtractCtx

func ExtractCtx(message *kafka.Message) (opentracing.SpanContext, error)

func Headers

func Headers(ctx context.Context, msgHeaders []kafka.Header) []kafka.Header

func New

func New(cfg config.Jaeger) (opentracing.Tracer, io.Closer, error)

func Setup

func Setup(cfg config.Jaeger) (io.Closer, error)

func StartChildSpan

func StartChildSpan(ctx context.Context, name string) opentracing.Span

func StartSpan

func StartSpan(name string) opentracing.Span

func StartSpanFromMessage

func StartSpanFromMessage(name string, msg *kafka.Message) opentracing.Span

Types

type KafkaHeaders

type KafkaHeaders []kafka.Header

func (*KafkaHeaders) ForeachKey

func (h *KafkaHeaders) ForeachKey(handler func(key, val string) error) error

func (*KafkaHeaders) Set

func (h *KafkaHeaders) Set(key, val string)