tel

package module

Go to main page

Versions in this module

v0

v0.4.0

Aug 2, 2026

Changes in this version

+ func AuditConfig(snap *env.EnvSnapshot) env.AuditReport

+ func AuditConfigFromEnviron() env.AuditReport

+ func AuditConfigWithOptions(snap *env.EnvSnapshot, opts env.AuditOptions) env.AuditReport

+ func MessagingConsumer(consumer string) attribute.KeyValue

+ func MessagingDeliveryCount(n int64) attribute.KeyValue

+ func MessagingOperationReply() attribute.KeyValue

+ func MessagingOperationRequest() attribute.KeyValue

+ func MessagingStream(stream string) attribute.KeyValue

+ func MessagingStreamSequence(seq int64) attribute.KeyValue

type AttrCache

+ func (c *AttrCache) Allow(labels ...string)

+ func (c *AttrCache) DenyUnknown() bool

+ func (c *AttrCache) MaxEntries() int

+ func (c *AttrCache) SetDenyUnknown(deny bool)

+ func (c *AttrCache) Subject2Opts(a, b string) []metric.AddOption

+ func (c *AttrCache) Subject2RecordOpts(a, b string) []metric.RecordOption

+ func (c *AttrCache) Subject3Opts(a, b, c3 string) []metric.AddOption

+ func (c *AttrCache) Subject3RecordOpts(a, b, c3 string) []metric.RecordOption

+ func (c *AttrCache) Subjects() []string

type CardinalityDetectorConfig

+ DenyUnknown bool

+ WarnUtilizationPct int

+ type CardinalitySnapshot struct

+ CacheEntries int

+ DeniedEvents int64

+ DenyUnknown bool

+ Instruments int

+ MaxCardinality int

+ MaxInstruments int

+ MissEvents int64

+ OverflowEvents int64

+ Subjects []string

+ UtilizationPct int

+ WarnUtilizationPct int

type FastCounter

+ func (c *FastCounter) AddWith2(ctx context.Context, n int64, subject, status string)

+ func (c *FastCounter) AddWith3(ctx context.Context, n int64, subject, status, consumer string)

type FastGauge

+ func (g *FastGauge) RecordWith2(ctx context.Context, value int64, subject, status string)

+ func (g *FastGauge) RecordWith3(ctx context.Context, value int64, subject, status, consumer string)

type FastHistogram

+ func (h *FastHistogram) RecordWith2(ctx context.Context, value float64, subject, status string)

+ func (h *FastHistogram) RecordWith3(ctx context.Context, value float64, subject, status, consumer string)

type Telemetry

+ func NewWithProviders(cfg Config, mp metric.MeterProvider, tp trace.TracerProvider) *Telemetry

+ func (t *Telemetry) AllowSubjects(labels ...string)

+ func (t *Telemetry) CardinalityStats() CardinalitySnapshot

type Timer

+ func (t *Timer) StopWith2(ctx context.Context, subject, status string)

+ func (t *Timer) StopWith3(ctx context.Context, subject, status, consumer string)

v0.3.0

Aug 1, 2026

Changes in this version

+ const FieldDurationMs

+ const FieldDurationS

+ const FieldEnvironment

+ const FieldFunction

+ const FieldNamespace

+ const FieldPod

+ const FieldService

+ const FieldSpanID

+ const FieldTraceID

+ const FieldVersion

+ func DebugCtx(ctx context.Context) *zerolog.Event

+ func Duration(e *zerolog.Event, d time.Duration) *zerolog.Event

+ func ErrorCtx(ctx context.Context) *zerolog.Event

+ func Extract(ctx context.Context, carrier propagation.TextMapCarrier) context.Context

+ func Func(e *zerolog.Event, name string) *zerolog.Event

+ func InfoCtx(ctx context.Context) *zerolog.Event

+ func Inject(ctx context.Context, carrier propagation.TextMapCarrier)

+ func MustReloadConfig(cfg *Config)

+ func ReloadConfig(cfg *Config) error

+ func StatusTraceIDRatioBased(fraction float64) sdktrace.Sampler

+ func TraceFunc(ctx context.Context, name string, fn func(context.Context) error) error

+ func WarnCtx(ctx context.Context) *zerolog.Event

+ func WithFields(ctx context.Context, fields ...Field) context.Context

+ type CardinalityDetectorConfig struct

+ DiagnosticInterval time.Duration

+ Enable bool

+ MaxCardinality int

+ MaxInstruments int

type Config

+ MaxLevelMessagesPerSecond string

+ MaxMessagesPerSecond int

+ MonitorConfig MonitorConfig

+ Pod string

+ TelConfig TelConfig

+ func GetConfigFromEnv() (Config, error)

+ func LoadConfig() (Config, error)

+ func LoadConfigFrom(snap *env.EnvSnapshot) (Config, error)

+ func MustLoadConfig() Config

+ type Field struct

+ Bool bool

+ Int int64

+ Key string

+ Kind uint8

+ Str string

+ func BoolField(key string, val bool) Field

+ func IntField(key string, val int64) Field

+ func StrField(key, val string) Field

type LoggerOptions

+ Pretty bool

+ type MetricsConfig struct

+ CardinalityDetector CardinalityDetectorConfig

+ EnableRetry bool

+ type RateSampler struct

+ func NewRateSampler(globalLimit int, levelLimits map[zerolog.Level]uint64) *RateSampler

+ func (s *RateSampler) Sample(lvl zerolog.Level) bool

+ type TLSRawConfig struct

+ CA []byte

+ Cert []byte

+ Key []byte

type Telemetry

+ func Init(ctx context.Context) (*Telemetry, func(context.Context) error)

+ func InitWithConfig(ctx context.Context, cfg Config) (*Telemetry, func(context.Context) error, error)

+ type TracesConfig struct

+ Enable bool

+ Sampler string

v0.2.1

Jul 31, 2026

v0.2.0

Jul 31, 2026

Changes in this version

+ func ConfigureLogger(cfg Config)

+ func Ctx(ctx context.Context) *zerolog.Logger

+ func Debug() *zerolog.Event

+ func EndSpan(span trace.Span, err error)

+ func Error() *zerolog.Event

+ func ExtractContext(ctx context.Context, headers map[string][]string) context.Context

+ func Info() *zerolog.Event

+ func InitLogger(opts LoggerOptions)

+ func InjectContext(ctx context.Context, headers map[string][]string) map[string][]string

+ func Logger() zerolog.Logger

+ func MessagingOperationProcess() attribute.KeyValue

+ func MessagingOperationPublish() attribute.KeyValue

+ func MessagingSubject(subject string) attribute.KeyValue

+ func MessagingSystem() attribute.KeyValue

+ func SetExitFunc(fn func(int))

+ func SetGlobal(t *Telemetry)

+ func SetLogger(l zerolog.Logger)

+ func Warn() *zerolog.Event

+ func WrapContext(ctx context.Context, l *Telemetry) context.Context

+ type AttrCache struct

+ func (c *AttrCache) Len() int

+ func (c *AttrCache) SetDetector(d *cardinalityDetector)

+ func (c *AttrCache) Subject(subject string) attribute.Set

+ func (c *AttrCache) SubjectOpts(subject string) []metric.AddOption

+ func (c *AttrCache) SubjectRecordOpts(subject string) []metric.RecordOption

+ type Config struct

+ Debug bool

+ Environment string

+ LogEncode string

+ LogLevel string

+ Namespace string

+ Service string

+ Version string

+ func DefaultConfig() Config

+ func DefaultDebugConfig() Config

+ type FastCounter struct

+ func (c *FastCounter) Add(ctx context.Context, n int64)

+ func (c *FastCounter) AddWith(ctx context.Context, n int64, subject string)

+ func (c *FastCounter) WithAttrs(attrs attribute.Set) *FastCounter

+ type FastGauge struct

+ func (g *FastGauge) Record(ctx context.Context, value int64)

+ func (g *FastGauge) RecordWith(ctx context.Context, value int64, subject string)

+ func (g *FastGauge) WithAttrs(attrs attribute.Set) *FastGauge

+ type FastHistogram struct

+ func (h *FastHistogram) Record(ctx context.Context, value float64)

+ func (h *FastHistogram) RecordWith(ctx context.Context, value float64, subject string)

+ func (h *FastHistogram) WithAttrs(attrs attribute.Set) *FastHistogram

+ type FatalEvent struct

+ func Fatal() *FatalEvent

+ func (f *FatalEvent) Err(err error) *FatalEvent

+ func (f *FatalEvent) Msg(msg string)

+ func (f *FatalEvent) Msgf(format string, v ...any)

+ func (f *FatalEvent) Str(key, val string) *FatalEvent

+ type HistogramOpt struct

+ Boundaries []float64

+ Name string

+ type LoggerOptions struct

+ JSON bool

+ Level string

+ type MonitorConfig struct

+ Enable bool

+ MonitorAddr string

+ type Registry struct

+ func (r *Registry) AttrCache() *AttrCache

+ func (r *Registry) Counter(name string, opts ...metric.Int64CounterOption) (*FastCounter, error)

+ func (r *Registry) Gauge(name string, opts ...metric.Int64GaugeOption) (*FastGauge, error)

+ func (r *Registry) Histogram(name string, opts ...metric.Float64HistogramOption) (*FastHistogram, error)

+ type TelConfig struct

+ Address string

+ BucketView []HistogramOpt

+ Enable bool

+ ExportIntervalSec int

+ Metrics struct{ ... }

+ MetricsPeriodicIntervalSec int

+ Raw struct{ ... }

+ ServerName string

+ Traces struct{ ... }

+ WithCompression bool

+ WithInsecure bool

+ type Telemetry struct

+ func FromCtx(ctx context.Context) *Telemetry

+ func Global() *Telemetry

+ func New() *Telemetry

+ func NewWithConfig(cfg Config) *Telemetry

+ func NewWithTracerProvider(cfg Config, provider trace.TracerProvider) *Telemetry

+ func (t *Telemetry) Config() Config

+ func (t *Telemetry) Meter(ins string, opts ...metric.MeterOption) metric.Meter

+ func (t *Telemetry) Registry() *Registry

+ func (t *Telemetry) Shutdown(ctx context.Context) error

+ func (t *Telemetry) Start(ctx context.Context) error

+ func (t *Telemetry) StartSpan(ctx context.Context, spanName string, opts ...trace.SpanStartOption) (context.Context, trace.Span)

+ func (t *Telemetry) Tracer(name string) trace.Tracer

+ type Timer struct

+ func NewTimer(hist *FastHistogram) Timer

+ func (t *Timer) Start()

+ func (t *Timer) Stop(ctx context.Context)

+ func (t *Timer) StopWith(ctx context.Context, subject string)

v0.1.1

Jul 24, 2026

v0.1.0

Jul 24, 2026

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL