whalert

type Deps struct {
	DB       *sql.DB
	Settings SettingsStore
	Reader   Reader
	Sources  SourceLister
	Engine   *levelalert.Engine
	// Grace is the compactor's grace after a window ends.
	Grace    time.Duration
	BaseURL  string
	Interval time.Duration
	Now      func() time.Time
}

type Input struct {
	Channels               *[]string               `json:"channels,omitempty"`
	SpoolFillPercent       *levelalert.Thresholds  `json:"spool_fill_percent,omitempty"`
	SpoolAgePercent        *levelalert.Thresholds  `json:"spool_age_percent,omitempty"`
	DrainFailures          *levelalert.Thresholds  `json:"drain_failures,omitempty"`
	DrainFailingMinutes    *float64                `json:"drain_failing_minutes,omitempty"`
	NotReportingSeconds    *float64                `json:"not_reporting_seconds,omitempty"`
	SpoolVolumeFreePercent *levelalert.Thresholds  `json:"spool_volume_free_percent,omitempty"`
	Defaults               *SourceRules            `json:"defaults,omitempty"`
	Sources                *map[string]SourceRules `json:"sources,omitempty"`
}

type Reader interface {
	SpoolStates(ctx context.Context) ([]whstore.SpoolState, error)
	AlertReadings(ctx context.Context, countsSince, ackSince time.Time) (map[string]*whstore.SourceReadings, error)
}

type Readings struct {
	Now time.Time
	// Sources are the sources that exist, by name; Enabled is whether each
	// receives.
	Sources map[string]bool
	Spools  []whstore.SpoolState
	// PerSource is each source's request counts, latency and compaction.
	PerSource map[string]*whstore.SourceReadings
	// Grace is how long after a window ends the compactor waits for its
	// segments, so a window is late only past it.
	Grace time.Duration
	// BaseURL is the portal's address; the alerts link to the webhooks
	// page under it. Empty omits the link.
	BaseURL string
}

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

type Settings struct {
	Channels []string `json:"channels"`
	// SpoolFillPercent is a replica's spool bytes as a percent of its
	// max_bytes.
	SpoolFillPercent levelalert.Thresholds `json:"spool_fill_percent"`
	// SpoolAgePercent is the oldest event waiting as a percent of max_age.
	SpoolAgePercent levelalert.Thresholds `json:"spool_age_percent"`
	// DrainFailures is how many drains in a row have failed; a streak
	// longer than DrainFailingMinutes is critical however many it counts.
	DrainFailures       levelalert.Thresholds `json:"drain_failures"`
	DrainFailingMinutes float64               `json:"drain_failing_minutes"`
	// NotReportingSeconds is how long a replica whose spool holds events
	// may go without reporting before it is critical.
	NotReportingSeconds float64 `json:"not_reporting_seconds"`
	// SpoolVolumeFreePercent is the free space left on the volume a spool
	// is on.
	SpoolVolumeFreePercent levelalert.Thresholds `json:"spool_volume_free_percent"`
	// Sources holds the per-source conditions: the defaults every source is
	// judged by, and any source's own.
	Defaults SourceRules            `json:"defaults"`
	Sources  map[string]SourceRules `json:"sources"`
}

type SettingsStore interface {
	Get(ctx context.Context) (settingsjson.Stored[Settings], error)
	Set(ctx context.Context, v Settings, author string) error
}

type SourceLister interface {
	List(ctx context.Context) ([]whsource.Source, error)
}

type SourceRules struct {
	// RefusalMinutes is the span refusals (spool_full, write_failed,
	// buffer_full) are judged over: any in it is a warning, one in every
	// minute of it is critical. Zero is off.
	RefusalMinutes *int `json:"refusal_minutes,omitempty"`
	// UnauthorizedPercent is the share of the source's requests over the
	// last 15 minutes that were refused as unauthorized.
	UnauthorizedPercent *levelalert.Thresholds `json:"unauthorized_percent,omitempty"`
	// AckP99MS is the 99th percentile acknowledgement over the last five
	// minutes, in milliseconds.
	AckP99MS *levelalert.Thresholds `json:"ack_p99_ms,omitempty"`
	// CompactionOverdueMinutes is how long past its end and the compactor's
	// grace the oldest window owed a compaction has waited.
	CompactionOverdueMinutes *levelalert.Thresholds `json:"compaction_overdue_minutes,omitempty"`
	// SilentAfterMinutes, when set, warns once the source has written no
	// segment for that long. Off unless a source opts in.
	SilentAfterMinutes *int `json:"silent_after_minutes,omitempty"`
}

type View struct {
	Settings
	UpdatedBy string `json:"updated_by,omitempty"`
	UpdatedAt string `json:"updated_at,omitempty"`
}