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 {
	TenantID      string
	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 {
	TenantID  string
	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)
	// AddCounter adds a non-negative delta in one operation. Token and byte
	// totals must use this instead of issuing one IncCounter call per unit.
	AddCounter(ctx context.Context, name MetricName, value float64, 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, value float64, attrs ...Attribute)

type RunQuery struct {
	TenantID string
	Status   RunStatus
	Limit    int
	Offset   int
}

type RunStatus string

type RunSummary struct {
	RunID         string         `json:"run_id"`
	TenantID      string         `json:"tenant_id,omitempty"`
	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 {
	TenantID  string
	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)
}