Versions in this module Expand all Collapse all v0 v0.2.0 Oct 13, 2026 Changes in this version + func ExtractHeaders(ctx context.Context, h map[string][]string) context.Context + func InjectHeaders(ctx context.Context, h map[string][]string) + type MQStats struct + Connections int64 + InMsgs int64 v0.1.0 Aug 19, 2026 Changes in this version + func ExtractNATS(ctx context.Context, msg HeaderHolder) context.Context + func InitProvider(ctx context.Context, serviceName string, cfg ProviderConfig) (func(context.Context) error, http.Handler, error) + func InjectNATS(ctx context.Context, msg *nats.Msg) + func NewLogger(component string, level *slog.LevelVar, isJSON bool, otlpSampleRate float64) *slog.Logger + func RegisterSystemMetrics(natsServer *server.Server, dedup dedupe.Deduplicator) error + type HeaderHolder interface + Headers func() nats.Header + type ProviderConfig struct + LogsEnabled bool + MetricsEnabled bool + PrometheusEnabled bool + TracesEnabled bool + TracesSampleRate float64 + type TraceHandler struct + func (h *TraceHandler) Handle(ctx context.Context, r slog.Record) error + func (h *TraceHandler) WithAttrs(attrs []slog.Attr) slog.Handler + func (h *TraceHandler) WithGroup(name string) slog.Handler
Go to main page