telemetry

May 3, 2026

Changes in this version

+ const InstrumentationName

+ type Metrics struct

+ BatchSize metric.Int64Histogram

+ EndToEndLatency metric.Float64Histogram

+ EventsTotal metric.Int64Counter

+ OldestPendingSeconds metric.Int64Gauge

+ PendingGauge metric.Int64Gauge

+ PublisherLatency metric.Float64Histogram

+ RelayStateGauge metric.Int64Gauge

+ StorageLatency metric.Float64Histogram

+ func NewMetrics(meterProvider metric.MeterProvider) (*Metrics, error)

+ type OTelProviders struct

+ MeterProvider *metric.MeterProvider

+ Shutdown func(context.Context) error

+ TraceProvider *trace.TracerProvider

+ func NewOTelProviders(ctx context.Context, cfg *config.Config) (*OTelProviders, error)

+ type Telemetry struct

+ Logger *zap.Logger

+ Meter metric.Meter

+ Metrics *Metrics

+ Tracer trace.Tracer

+ func (t Telemetry) ScopedLogger(moduleName string) *zap.Logger