kotel

Jun 8, 2024

Changes in this version

type MeterOpt

+ func WithMergedConnectsMeter() MeterOpt

Mar 14, 2023

Changes in this version

type TracerOpt

+ func KeyFormatter(fn func(*kgo.Record) (string, error)) TracerOpt

Feb 8, 2023

Changes in this version

+ type Kotel struct

+ func NewKotel(opts ...Opt) *Kotel

+ func (k *Kotel) Hooks() []kgo.Hook

+ type Meter struct

+ func NewMeter(opts ...MeterOpt) *Meter

+ func (m *Meter) OnBrokerConnect(meta kgo.BrokerMetadata, _ time.Duration, _ net.Conn, err error)

+ func (m *Meter) OnBrokerDisconnect(meta kgo.BrokerMetadata, _ net.Conn)

+ func (m *Meter) OnBrokerRead(meta kgo.BrokerMetadata, _ int16, bytesRead int, _, _ time.Duration, err error)

+ func (m *Meter) OnBrokerWrite(meta kgo.BrokerMetadata, _ int16, bytesWritten int, _, _ time.Duration, ...)

+ func (m *Meter) OnFetchBatchRead(meta kgo.BrokerMetadata, topic string, _ int32, fbm kgo.FetchBatchMetrics)

+ func (m *Meter) OnProduceBatchWritten(meta kgo.BrokerMetadata, topic string, _ int32, pbm kgo.ProduceBatchMetrics)

+ type MeterOpt interface

+ func MeterProvider(provider metric.MeterProvider) MeterOpt

+ type Opt interface

+ func WithMeter(m *Meter) Opt

+ func WithTracer(t *Tracer) Opt

+ type RecordCarrier struct

+ func NewRecordCarrier(record *kgo.Record) RecordCarrier

+ func (c RecordCarrier) Get(key string) string

+ func (c RecordCarrier) Keys() []string

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

+ type Tracer struct

+ func NewTracer(opts ...TracerOpt) *Tracer

+ func (t *Tracer) OnFetchRecordBuffered(r *kgo.Record)

+ func (t *Tracer) OnFetchRecordUnbuffered(r *kgo.Record, _ bool)

+ func (t *Tracer) OnProduceRecordBuffered(r *kgo.Record)

+ func (t *Tracer) OnProduceRecordUnbuffered(r *kgo.Record, err error)

+ func (t *Tracer) WithProcessSpan(r *kgo.Record) (context.Context, trace.Span)

+ type TracerOpt interface

+ func ClientID(id string) TracerOpt

+ func ConsumerGroup(group string) TracerOpt

+ func TracerPropagator(propagator propagation.TextMapPropagator) TracerOpt

+ func TracerProvider(provider trace.TracerProvider) TracerOpt