telemetry

Apr 9, 2026

Changes in this version

type RegistryMetrics

+ func (m *RegistryMetrics) RecordSkillsTotal(ctx context.Context, registryName string, count int64)

Feb 5, 2026

Changes in this version

+ const MaxUserAgentLength

+ const TracerName

+ func TracingMiddleware(provider trace.TracerProvider) func(http.Handler) http.Handler

Jan 28, 2026

Changes in this version

+ const DefaultEndpoint

+ const DefaultMetricsInterval

+ const DefaultSampling

+ const DefaultServiceName

+ const HTTPMetricsMeterName

+ const RegistryMetricsMeterName

+ const SyncMetricsMeterName

+ func MetricsMiddleware(provider metric.MeterProvider) (func(http.Handler) http.Handler, error)

+ func NewMeterProvider(ctx context.Context, opts ...MeterProviderOption) (metric.MeterProvider, error)

+ func NewTracerProvider(ctx context.Context, opts ...TracerProviderOption) (trace.TracerProvider, error)

+ type Config struct

+ Enabled bool

+ Endpoint string

+ Insecure bool

+ Metrics *MetricsConfig

+ ServiceName string

+ ServiceVersion string

+ Tracing *TracingConfig

+ func (c *Config) GetEndpoint() string

+ func (c *Config) GetInsecure() bool

+ func (c *Config) GetServiceName() string

+ func (c *Config) GetServiceVersion() string

+ func (c *Config) Validate() error

+ type HTTPMetrics struct

+ func NewHTTPMetrics(provider metric.MeterProvider) (*HTTPMetrics, error)

+ func (m *HTTPMetrics) Middleware(next http.Handler) http.Handler

+ type MeterProviderOption func(*meterProviderConfig)

+ func WithMeterEndpoint(endpoint string) MeterProviderOption

+ func WithMeterInsecure(insecure bool) MeterProviderOption

+ func WithMeterServiceName(name string) MeterProviderOption

+ func WithMeterServiceVersion(version string) MeterProviderOption

+ func WithMetricsConfig(mc *MetricsConfig) MeterProviderOption

+ type MetricsConfig struct

+ Enabled bool

+ func (c *MetricsConfig) Validate() error

+ type Option func(*telemetryConfig)

+ func WithTelemetryConfig(cfg *Config) Option

+ type RegistryMetrics struct

+ func NewRegistryMetrics(provider metric.MeterProvider) (*RegistryMetrics, error)

+ func (m *RegistryMetrics) RecordServersTotal(ctx context.Context, registryName string, count int64)

+ type SyncMetrics struct

+ func NewSyncMetrics(provider metric.MeterProvider) (*SyncMetrics, error)

+ func (m *SyncMetrics) RecordSyncDuration(ctx context.Context, registryName string, duration time.Duration, success bool)

+ type Telemetry struct

+ func New(ctx context.Context, opts ...Option) (*Telemetry, error)

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

+ func (t *Telemetry) MeterProvider() metric.MeterProvider

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

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

+ func (t *Telemetry) TracerProvider() trace.TracerProvider

+ type TracerProviderOption func(*tracerProviderConfig)

+ func WithTracerEndpoint(endpoint string) TracerProviderOption

+ func WithTracerInsecure(insecure bool) TracerProviderOption

+ func WithTracerServiceName(name string) TracerProviderOption

+ func WithTracerServiceVersion(version string) TracerProviderOption

+ func WithTracingConfig(tc *TracingConfig) TracerProviderOption

+ type TracingConfig struct

+ Enabled bool

+ Sampling float64

+ func (c *TracingConfig) GetSampling() float64

+ func (c *TracingConfig) Validate() error