alerts

type AlertFire struct {
	AlertName   string           `json:"alert"`
	EvaluatedAt time.Time        `json:"evaluated_at"`
	RowCount    int64            `json:"row_count"` // true count, pre-truncation
	Rows        []map[string]any `json:"rows"`      // capped at MaxRowsPerFire
	Truncated   bool             `json:"truncated"`
	Schema      []ColumnMeta     `json:"schema"`
}

type AlertSink interface {
	Name() string
	Deliver(ctx context.Context, fire AlertFire) error
}

type ColumnMeta struct {
	Name string `json:"name"`
	Type string `json:"type"`
}

type EvalContextFunc func(ctx context.Context, m catalog.AlertMeta) context.Context

type SQLExecutor interface {
	// Execute runs a mutation statement (INSERT INTO ...). Returns an error
	// on failure; no result is surfaced.
	Execute(ctx context.Context, sql string) error

	// Query runs a SELECT and returns rows as []map[string]any plus a schema.
	// Implementations should cap the number of rows returned to at most limit.
	// If the underlying result has more rows, truncated is true and total is
	// the true (pre-truncation) row count.
	Query(ctx context.Context, sql string, limit int) (rows []map[string]any, schema []ColumnMeta, total int64, truncated bool, err error)
}

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

type SinkFactory func(m catalog.AlertMeta) []AlertSink

type SinkResult struct {
	Sink  string `json:"sink"`
	OK    bool   `json:"ok"`
	Error string `json:"error,omitempty"`
}

type TableSink struct {
	Executor SQLExecutor
	// Now is a clock injection seam for tests. Defaults to time.Now.
	Now func() time.Time
	// Results captured from sibling sinks, embedded in the history row.
	// The scheduler sets this before calling Deliver.
	Results []SinkResult
}

type WebhookSink struct {
	AlertName string
	URL       string
	Headers   map[string]string
	Client    *http.Client
	// contains filtered or unexported fields
}