client

type Alert struct {
	// Labels are the alert labels.
	Labels map[string]string
	// State is the alert state (active, suppressed, unprocessed).
	State string
	// StartsAt is when the alert started firing.
	StartsAt time.Time
	// EndsAt is when the alert stopped firing (zero if still active).
	EndsAt time.Time
}

type AlertFilters struct {
	// Matchers are label matchers to filter alerts (e.g., alertname=~"HighLatency").
	Matchers []string
}

type AlertManagerClient interface {
	// GetAlerts retrieves active alerts matching the given filters.
	GetAlerts(ctx context.Context, filters AlertFilters) ([]Alert, error)

	// Ready checks if AlertManager is ready to accept queries.
	Ready(ctx context.Context) error
}

type DataStorageQuerier interface {
	// QueryPreRemediationHash queries DS for the pre-remediation spec hash
	// associated with a given correlation ID. Returns empty string if not found.
	QueryPreRemediationHash(ctx context.Context, correlationID string) (string, error)

	// HasWorkflowStarted checks if a workflowexecution.workflow.started event
	// exists for the given correlation ID. Returns false if not found.
	// ADR-EM-001 Section 5: Used to detect the no_execution path.
	HasWorkflowStarted(ctx context.Context, correlationID string) (bool, error)
}

type PrometheusQuerier interface {
	// Query executes an instant PromQL query and returns the result.
	Query(ctx context.Context, query string, ts time.Time) (*QueryResult, error)

	// QueryRange executes a range PromQL query and returns the result.
	QueryRange(ctx context.Context, query string, start, end time.Time, step time.Duration) (*QueryResult, error)

	// Ready checks if Prometheus is ready to accept queries.
	Ready(ctx context.Context) error
}

type QueryResult struct {
	// Samples contains the data points returned by the query.
	Samples []Sample
}

type Sample struct {
	// Metric is the metric name and labels.
	Metric map[string]string
	// Value is the sample value.
	Value float64
	// Timestamp is the sample timestamp.
	Timestamp time.Time
}