observability

type Attribute struct {
	Key   string
	Value string
}

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

type EventPublisher interface {
	PublishEvent(ctx context.Context, record EventRecord) error
}

type EventQuery struct {
	AfterSequence int64
	Limit         int
	// Preset selects a read-side event view (product_ui or diagnostic).
	// Empty defaults to diagnostic (full stream). Filtering is projection-only;
	// Append always stores every event.
	Preset core.EventFilterPreset
}

type EventRecord struct {
	ID        int64      `json:"id"`
	Sequence  int64      `json:"sequence"`
	Event     core.Event `json:"event"`
	CreatedAt time.Time  `json:"created_at"`
}

type EventRunPurger interface {
	EventStore
	DeleteEventsForRun(ctx context.Context, runID string) (int64, error)
}

type EventStore interface {
	Append(ctx context.Context, event core.Event) (EventRecord, error)
	ListRuns(ctx context.Context, query RunQuery) ([]RunSummary, error)
	ListEvents(ctx context.Context, runID string, query EventQuery) ([]EventRecord, error)
	ListScopedEvents(ctx context.Context, query ScopedEventQuery) ([]EventRecord, error)
}

type EventStorePurger interface {
	EventStore
	PurgeEventsBefore(ctx context.Context, cutoff time.Time) (int64, error)
}

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

type EventSubscription struct {
	Events <-chan EventRecord
	Cancel func()
}

type EventSubscriptionFilter struct {
	RunID     string
	EpisodeID string
	SessionID string
	Buffer    int
}

type MetricName string

type NoopRecorder struct{}

type NoopTracer struct{}

type Recorder interface {
	IncCounter(ctx context.Context, name MetricName, attrs ...Attribute)
	ObserveHistogram(ctx context.Context, name MetricName, value float64, attrs ...Attribute)
	SetGauge(ctx context.Context, name MetricName, value float64, attrs ...Attribute)
}

type RecorderFunc func(ctx context.Context, name MetricName, attrs ...Attribute)

type RunQuery struct {
	Status RunStatus
	Limit  int
	Offset int
}

type RunStatus string

type RunSummary struct {
	RunID         string         `json:"run_id"`
	ScenarioName  string         `json:"scenario_name,omitempty"`
	Status        RunStatus      `json:"status"`
	EventCount    int64          `json:"event_count"`
	FirstSeenAt   time.Time      `json:"first_seen_at"`
	LastSeenAt    time.Time      `json:"last_seen_at"`
	LastEventType core.EventType `json:"last_event_type"`
}

type ScopedEventQuery struct {
	EpisodeID string
	SessionID string
	AfterID   int64
	Limit     int
	Preset    core.EventFilterPreset
}

type SequencedEventStore interface {
	EventStore
	AppendSequenced(ctx context.Context, sequence int64, event core.Event) (EventRecord, error)
}

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

type SpanName string

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