telemetry

type Attribute ¶

type Attribute struct {
	Key   string
	Value any
}

Attribute is a key-value pair for spans and metrics.

type Counter ¶

type Counter interface {
	Add(ctx context.Context, delta int64)
}

Counter records monotonically increasing values.

type Gauge ¶

type Gauge interface {
	Set(ctx context.Context, value float64)
}

Gauge records current values.

type Histogram ¶

type Histogram interface {
	Record(ctx context.Context, value float64)
}

Histogram records distribution of values.

type Meter ¶

type Meter interface {
	Counter(name string, attrs ...Attribute) Counter
	Histogram(name string, attrs ...Attribute) Histogram
	Gauge(name string, attrs ...Attribute) Gauge
}

Meter creates and records metrics.

type OTLPExporter ¶

type OTLPExporter struct {
	// contains filtered or unexported fields
}

OTLPExporter sends spans and metrics to an OTLP-compatible endpoint over HTTP/JSON.

func NewOTLPExporter(opts ...OTLPOption) *OTLPExporter

func (e *OTLPExporter) Close()

func (e *OTLPExporter) ExportMetric(m otlpMetric)

func (e *OTLPExporter) ExportSpan(span otlpSpan)

func (e *OTLPExporter) Flush(ctx context.Context) error

type OTLPOption ¶

type OTLPOption func(*OTLPExporter)

OTLPOption configures an OTLPExporter.

func WithOTLPBatchSize(n int) OTLPOption

func WithOTLPEndpoint(url string) OTLPOption

type Option ¶

type Option = options.Option[Provider]

Option configures a Provider.

func WithMeter(m Meter) Option

func WithTracer(t Tracer) Option

type PrometheusExporter ¶

type PrometheusExporter struct {
	// contains filtered or unexported fields
}

func NewPrometheusExporter() *PrometheusExporter

func (p *PrometheusExporter) IncCounter(name string, delta int64)

func (p *PrometheusExporter) ObserveHistogram(name string, value float64, buckets []float64)

func (p *PrometheusExporter) SetGauge(name string, value float64)

func (p *PrometheusExporter) WriteText(w io.Writer)

type Provider ¶

type Provider struct {
	Tracer Tracer
	Meter  Meter
	// contains filtered or unexported fields
}

Provider is the central telemetry hub.

func NewProvider(opts ...Option) *Provider

func (p *Provider) Shutdown()

type SimpleMeter ¶

type SimpleMeter struct {
	// contains filtered or unexported fields
}

SimpleMeter is a basic meter that stores counters in memory.

func NewSimpleMeter() *SimpleMeter

func (m *SimpleMeter) Counter(name string, attrs ...Attribute) Counter

func (m *SimpleMeter) Gauge(name string, attrs ...Attribute) Gauge

func (m *SimpleMeter) GetCounter(name string) int64

func (m *SimpleMeter) GetGauge(name string) float64

func (m *SimpleMeter) Histogram(name string, attrs ...Attribute) Histogram

type SimpleTracer ¶

type SimpleTracer struct {
	// contains filtered or unexported fields
}

SimpleTracer is a basic tracer that logs span starts and ends to stderr.

func NewSimpleTracer() *SimpleTracer

func (s *SimpleTracer) Start(ctx context.Context, name string, attrs ...Attribute) (Span, context.Context)

type Span ¶

type Span interface {
	SetAttributes(attrs ...Attribute)
	End()
}

Span represents an active span in a trace.

type TelemetryMiddleware ¶

type TelemetryMiddleware struct {
	Provider *Provider
}

func NewTelemetryMiddleware(provider *Provider) *TelemetryMiddleware

func (tm *TelemetryMiddleware) WrapHTTP(next http.Handler) http.Handler

type TraceContext ¶

type TraceContext struct {
	TraceID    string
	ParentID   string
	TraceFlags string
}

func ParseTraceparent(header string) (*TraceContext, error)

func (tc *TraceContext) Encode() string

type Tracer ¶

type Tracer interface {
	Start(ctx context.Context, name string, attrs ...Attribute) (Span, context.Context)
}

Tracer creates and manages spans.