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 ¶
func StartChildSpan ¶
func StartSpanFromMessage ¶
Types ¶
type KafkaHeaders ¶
func (*KafkaHeaders) ForeachKey ¶
func (h *KafkaHeaders) ForeachKey(handler func(key, val string) error) error
func (*KafkaHeaders) Set ¶
func (h *KafkaHeaders) Set(key, val string)
Source Files
Click to show internal directories.
Click to hide internal directories.