otel

Nov 4, 2026

Changes in this version

+ const MetricConsumedMessages

+ const MetricDeadLetters

+ const MetricProcessDuration

+ const MetricRetries

+ const MetricSentMessages

+ const SchemaURL

+ const SemconvVersion

+ func NewDeadLetterObserver(opts ...Option) babelqueue.DeadLetterObserver

+ type Option func(*config)

+ func WithConsumerGroup(group string) Option

+ func WithMeter(m metric.Meter) Option

+ func WithSystem(system string) Option

+ type Publisher struct

+ func NewPublisher(tracer trace.Tracer, app *babelqueue.App, opts ...Option) *Publisher

+ func (p *Publisher) Publish(ctx context.Context, urn string, data map[string]any, ...) (string, error)

Oct 20, 2026

Changes in this version

+ type Extracted struct

+ Flags string

+ ParentSpanID string

+ Source string

+ TraceIDHex string

+ func ExtractTraceparent(traceparent, envelopeTraceID string) Extracted

Jun 20, 2026

Changes in this version

+ const HeaderTraceparent

+ const HeaderTracestate

Jun 19, 2026

Changes in this version

+ func Publish(ctx context.Context, tracer trace.Tracer, app *babelqueue.App, urn string, ...) (string, error)

+ func TraceIDOf(traceID string) trace.TraceID

+ func UUIDOf(t trace.TraceID) string

+ func WrapHandler(tracer trace.Tracer, handler babelqueue.Handler) babelqueue.Handler