telemetry

type Attrs map[string]string

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

type BridgeConfig struct {
	Timeout time.Duration
}

type ContextServiceInvoker interface {
	InvokeServiceContext(context.Context, string, map[string]any) (map[string]any, error)
}

type LogEmitter interface {
	DrainTelemetryLogs(context.Context) []LogRecord
}

type LogRecord struct {
	Timestamp time.Time
	Level     string
	Message   string
	Module    string
	Attrs     Attrs
}

type MetricEmitter interface {
	EmitMetrics(context.Context, MetricRecorder) error
}

type MetricKind string

type MetricRecord struct {
	Name      string
	Kind      MetricKind
	Value     float64
	Attrs     Attrs
	Timestamp time.Time
}

type MetricRecorder interface {
	Counter(name string, value float64, attrs Attrs)
	Gauge(name string, value float64, attrs Attrs)
	Histogram(name string, value float64, attrs Attrs)
}

type NoopSink struct{}

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

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

type SpanEvent struct {
	Name      string
	Attrs     Attrs
	Timestamp time.Time
}

type SpanRecorder interface {
	Event(name string, attrs Attrs)
	Attribute(key, value string)
}

type TelemetrySink interface {
	RecordMetrics(context.Context, []MetricRecord) error
	RecordLogs(context.Context, []LogRecord) error
	RecordSpanEvents(context.Context, []SpanEvent) error
}

type TraceAnnotator interface {
	AnnotateSpan(context.Context, SpanRecorder)
}