alerts

type Alert struct {
	// Kind selects a supported public alert category.
	Kind Kind `json:"kind"`
	// TenantID is scoped attribution retained for platform consumers, but
	// omitted from TelemetryExporter labels.
	TenantID string `json:"tenant_id"`
	// Resource identifies the breached queue/worker/command or aggregate count
	// category.
	Resource string `json:"resource"`
	// Value is a nonnegative observed count or seconds value; large uint64
	// counts may round in float64.
	Value float64 `json:"value"`
	// Threshold is the strict upper count/seconds threshold; status alerts use
	// zero.
	Threshold float64 `json:"threshold"`
	// ObservedAt is the UTC source/command/input observation time appropriate
	// to the category.
	ObservedAt time.Time `json:"observed_at"`
}

type Input struct {
	// TenantID is required bounded scope and must match all supplied
	// worker/command records.
	TenantID string
	// ObservedAt is required observation time for count and stale-worker
	// alerts.
	ObservedAt time.Time
	// Queues is a validated bounded queue-status page; unsupported age
	// measurements produce no alert.
	Queues queue.QueueStatusPage
	// Workers contains at most MaxWorkers validated scoped reports with derived
	// state.
	Workers fleet.RegistrySnapshot
	// Failures is an optional supported aggregate count; unsupported data is
	// not treated as zero evidence.
	Failures queue.Measurement[uint64]
	// DeadLetters is an optional supported aggregate dead-letter count.
	DeadLetters queue.Measurement[uint64]
	// Commands contains at most MaxCommands validated scoped outcomes; slices
	// remain caller-owned during Evaluate.
	Commands []controlplane.CommandResult
}

type Kind string

type Policy struct {
	// MaxQueueWait enables supported oldest-age alerts when positive; zero
	// disables and negative values fail.
	MaxQueueWait time.Duration
	// MaxFailures enables strictly greater supported count alerts when nonzero.
	MaxFailures uint64
	// MaxDeadLetters enables strictly greater supported dead-letter count
	// alerts when nonzero.
	MaxDeadLetters uint64
	// StaleWorkers enables one alert per derived stale worker.
	StaleWorkers bool
	// CommandFailures enables one alert per failed or unknown command.
	CommandFailures bool
}

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