tracing

Jun 5, 2025

Changes in this version

+ func Logger() instrumentation.Logger

+ type Header interface

+ GetKey func() string

+ GetValue func() []byte

+ type KafkaConfig struct

+ BootstrapServers string

+ ConsumerGroupID string

+ type KafkaHeader struct

+ Key string

+ Value []byte

+ func (h KafkaHeader) GetKey() string

+ func (h KafkaHeader) GetValue() []byte

+ type Message interface

+ GetHeaders func() []Header

+ GetKey func() []byte

+ GetOffset func() int64

+ GetPartition func() int

+ GetTopic func() string

+ GetValue func() []byte

+ SetHeaders func([]Header)

+ type MessageCarrier struct

+ func NewMessageCarrier(msg Message) MessageCarrier

+ func (c MessageCarrier) ForeachKey(handler func(key, val string) error) error

+ func (c MessageCarrier) Set(key, val string)

+ type Option interface

+ func WithAnalytics(on bool) Option

+ func WithAnalyticsRate(rate float64) Option

+ func WithDataStreams() Option

+ func WithService(serviceName string) Option

+ type OptionFn func(*Tracer)

+ type Tracer struct

+ func NewTracer(kafkaCfg KafkaConfig, opts ...Option) *Tracer

+ func (*Tracer) FinishProduceSpan(span *tracer.Span, partition int, offset int64, err error)

+ func (tr *Tracer) SetConsumeDSMCheckpoint(msg Message)

+ func (tr *Tracer) SetProduceDSMCheckpoint(msg Message, writer Writer)

+ func (tr *Tracer) StartConsumeSpan(ctx context.Context, msg Message) *tracer.Span

+ func (tr *Tracer) StartProduceSpan(ctx context.Context, writer Writer, msg Message, ...) *tracer.Span

+ type Writer interface

+ GetTopic func() string