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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ExtractCtx ¶ added in v1.1.3
func StartChildSpan ¶ added in v1.1.3
func StartSpanFromMessage ¶ added in v1.1.3
Types ¶
type KafkaHeaders ¶ added in v1.1.3
func (*KafkaHeaders) ForeachKey ¶ added in v1.1.3
func (h *KafkaHeaders) ForeachKey(handler func(key, val string) error) error
func (*KafkaHeaders) Set ¶ added in v1.1.3
func (h *KafkaHeaders) Set(key, val string)
Click to show internal directories.
Click to hide internal directories.