otel

type AgentEvent struct {
	// Type is the event type (loop.created, loop.completed, loop.failed, etc.)
	Type string `json:"type"`

	// LoopID is the agent loop identifier.
	LoopID string `json:"loop_id"`

	// TaskID is the task identifier (for task events).
	TaskID string `json:"task_id,omitempty"`

	// ToolName is the tool name (for tool events).
	ToolName string `json:"tool_name,omitempty"`

	// Timestamp is when the event occurred.
	Timestamp time.Time `json:"timestamp"`

	// EntityID is the agent's entity ID.
	EntityID string `json:"entity_id,omitempty"`

	// Role is the agent's role.
	Role string `json:"role,omitempty"`

	// Error is the error message for failure events.
	Error string `json:"error,omitempty"`

	// Duration is the operation duration (for completion events).
	Duration time.Duration `json:"duration,omitempty"`

	// Metadata contains additional event metadata.
	Metadata map[string]any `json:"metadata,omitempty"`
}

type BucketCount struct {
	// UpperBound is the bucket upper bound.
	UpperBound float64 `json:"upper_bound"`

	// Count is the cumulative count.
	Count uint64 `json:"count"`
}

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

type Config struct {
	// Ports defines the input/output port configuration.
	Ports *component.PortConfig `json:"ports" schema:"type:ports,description:Port configuration,category:basic"`

	// Endpoint is the OTEL collector endpoint.
	Endpoint string `json:"endpoint" schema:"type:string,description:OTLP HTTP collector base URL,category:basic,default:http://localhost:4318"`

	// Protocol specifies the export protocol.
	// Only OTLP/HTTP is currently implemented. Unsupported transports fail closed.
	Protocol string `json:"protocol" schema:"type:string,description:Export protocol,category:basic,default:http"`

	// ServiceName is the service name for OTEL traces.
	ServiceName string `json:"service_name" schema:"type:string,description:Service name for traces,category:basic,default:semstreams"`

	// ServiceVersion is the service version for OTEL traces.
	ServiceVersion string `json:"service_version" schema:"type:string,description:Service version,category:basic,default:1.0.0"`

	// ExportTraces enables trace export.
	ExportTraces bool `json:"export_traces" schema:"type:bool,description:Enable trace export,category:basic,default:true"`

	// ExportMetrics enables metric export.
	ExportMetrics bool `json:"export_metrics" schema:"type:bool,description:Enable metric export,category:basic,default:true"`

	// BatchTimeout is the timeout for batching exports.
	BatchTimeout string `json:"batch_timeout" schema:"type:string,description:Batch export timeout,category:advanced,default:5s"`

	// ExportTimeout is the timeout for each export operation.
	ExportTimeout string `json:"export_timeout" schema:"type:string,description:Export operation timeout,category:advanced,default:30s"`

	// Headers are additional headers to send with exports.
	Headers map[string]string `json:"headers" schema:"type:object,description:Additional export headers,category:advanced"`

	// SamplingRate is the trace sampling rate (0.0 to 1.0).
	SamplingRate float64 `json:"sampling_rate" schema:"type:float,description:Trace sampling rate,category:advanced,default:1.0"`

	// ConsumerNameSuffix adds a suffix to consumer names for uniqueness in tests.
	ConsumerNameSuffix string `json:"consumer_name_suffix" schema:"type:string,description:Suffix for consumer names,category:advanced"`
}

type DataPoint struct {
	// Timestamp is when the data point was recorded.
	Timestamp time.Time `json:"timestamp"`

	// Value is the metric value (for counter/gauge).
	Value float64 `json:"value,omitempty"`

	// Count is the count (for histogram/summary).
	Count uint64 `json:"count,omitempty"`

	// Sum is the sum (for histogram/summary).
	Sum float64 `json:"sum,omitempty"`

	// Buckets are histogram bucket counts.
	Buckets []BucketCount `json:"buckets,omitempty"`

	// Quantiles are summary quantile values.
	Quantiles []QuantileValue `json:"quantiles,omitempty"`

	// Attributes are data point attributes.
	Attributes map[string]any `json:"attributes,omitempty"`
}

type Exporter interface {
	// ExportSpans exports spans to the OTEL collector.
	ExportSpans(ctx context.Context, spans []*SpanData) error

	// ExportMetrics exports metrics to the OTEL collector.
	ExportMetrics(ctx context.Context, metrics []*MetricData) error

	// Shutdown gracefully shuts down the exporter.
	Shutdown(ctx context.Context) error
}

type MetricData struct {
	// Name is the metric name.
	Name string `json:"name"`

	// Description describes the metric.
	Description string `json:"description,omitempty"`

	// Unit is the metric unit.
	Unit string `json:"unit,omitempty"`

	// Type is the metric type.
	Type MetricType `json:"type"`

	// DataPoints contains the metric values.
	DataPoints []DataPoint `json:"data_points"`

	// Attributes are metric-level attributes.
	Attributes map[string]any `json:"attributes,omitempty"`
}

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

type MetricType string

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

type PrometheusMetric struct {
	Name   string
	Help   string
	Type   string
	Labels map[string]string
	Value  float64
	// For histograms
	Buckets map[float64]uint64
	Count   uint64
	Sum     float64
	// For summaries
	Quantiles map[float64]float64
}

type QuantileValue struct {
	// Quantile is the quantile (e.g., 0.5, 0.9, 0.99).
	Quantile float64 `json:"quantile"`

	// Value is the quantile value.
	Value float64 `json:"value"`
}

type RegistryInterface interface {
	RegisterWithConfig(config component.RegistrationConfig) error
}

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

type SpanData struct {
	// TraceID is the trace identifier.
	TraceID string `json:"trace_id"`

	// SpanID is the span identifier.
	SpanID string `json:"span_id"`

	// ParentSpanID is the parent span identifier.
	ParentSpanID string `json:"parent_span_id,omitempty"`

	// Name is the span name.
	Name string `json:"name"`

	// Kind is the span kind (client, server, internal, producer, consumer).
	Kind string `json:"kind"`

	// StartTime is when the span started.
	StartTime time.Time `json:"start_time"`

	// EndTime is when the span ended.
	EndTime time.Time `json:"end_time,omitempty"`

	// Status indicates the span status.
	Status SpanStatus `json:"status"`

	// Attributes are span attributes.
	Attributes map[string]any `json:"attributes,omitempty"`

	// Events are span events.
	Events []SpanEvent `json:"events,omitempty"`

	// Links are span links.
	Links []SpanLink `json:"links,omitempty"`
}

type SpanEvent struct {
	// Name is the event name.
	Name string `json:"name"`

	// Timestamp is when the event occurred.
	Timestamp time.Time `json:"timestamp"`

	// Attributes are event attributes.
	Attributes map[string]any `json:"attributes,omitempty"`
}

type SpanLink struct {
	// TraceID is the linked trace ID.
	TraceID string `json:"trace_id"`

	// SpanID is the linked span ID.
	SpanID string `json:"span_id"`

	// Attributes are link attributes.
	Attributes map[string]any `json:"attributes,omitempty"`
}

type SpanStatus struct {
	// Code is the status code (unset, ok, error).
	Code string `json:"code"`

	// Message is an optional status message.
	Message string `json:"message,omitempty"`
}