monitor

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

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

type Config struct {
	Enabled         bool
	Workers         int
	MinIntervalHTTP time.Duration
	MinIntervalTCP  time.Duration
	MaxTimeout      time.Duration
	MaxCount        int
	BodyMaxBytes    int
	MaxHeaders      int
	HeaderMaxBytes  int
	MaxRedirects    int
	FlushInterval   time.Duration
	BufferMax       int
	RawRetention    time.Duration
	HourRetention   time.Duration
	PruneInterval   time.Duration
	PruneBatch      int
	JitterPercent   int
	TickInterval    time.Duration
	ResultsMaxLimit int
	ConfirmFailures int
	RecoveryOKs     int
	UserAgent       string

	MinIntervalHeartbeat time.Duration
	MinIntervalTLS       time.Duration
	HeartbeatGrace       time.Duration
	HeartbeatMaxGrace    time.Duration
	HeartbeatCheck       time.Duration
	HeartbeatPerMinute   int
	HeartbeatBodyMax     int
	HeartbeatMinResponse time.Duration
	TLSWarnDays          int
	TLSCritDays          int
}

type CreateInput struct {
	Monitor Monitor
	Headers map[string]string
}

type HeartbeatState struct {
	MonitorID string
	TokenHash string
	ArmedAt   int64
	LastOK    int64
	LastStart int64
	LastFail  int64
}

type HeartbeatStore interface {
	SaveHeartbeatToken(ctx context.Context, monitorID, tokenHash string, armedAt int64) error
	FindHeartbeat(ctx context.Context, tokenHash string) (HeartbeatState, error)
	GetHeartbeat(ctx context.Context, monitorID string) (HeartbeatState, error)
	RecordHeartbeat(ctx context.Context, monitorID, signal string, at int64) error
}

type History struct {
	Raw    []Result
	Rollup []Rollup
}

type Monitor struct {
	ID        string
	Name      string
	Kind      string
	Interval  time.Duration
	Timeout   time.Duration
	Enabled   bool
	Spec      Spec
	CreatedAt time.Time
	// PingToken is the plaintext heartbeat token, set only on the Monitor returned by Create
	// and RotateToken. It is never stored: only its hash is.
	PingToken string
}

type Notifier func(Transition)

type Options struct {
	Config  Config
	Store   Store
	Secrets Secrets
	Logger  *slog.Logger
	// Notify receives confirmed down and recovered transitions; nil drops them.
	Notify Notifier
	// OnDelete runs after a monitor is removed so alert state tied to it can clear.
	OnDelete func(id string)
	// Heartbeats stores heartbeat tokens and pings; nil rejects heartbeat monitors.
	Heartbeats HeartbeatStore
}

type Result struct {
	MonitorID string
	At        int64
	OK        bool
	LatencyMS int
	Code      int
	Reason    string
	// Degraded marks a passing check that is close to failing, such as a certificate
	// inside its warning window. It is not stored, the Reason is.
	Degraded bool
}

type ResultSink interface {
	InsertResults(ctx context.Context, results []Result) error
}

type Rollup struct {
	MonitorID string
	Bucket    int64
	Total     int
	Failed    int
	LatSum    int64
	LatMax    int
}

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

type Secrets interface {
	SetValue(ctx context.Context, serviceName, envKey, plaintext string) error
	Resolve(ctx context.Context, serviceName, envKey string) (string, error)
	DeleteAll(ctx context.Context, serviceName string) error
}

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

type Spec struct {
	URL             string        `json:"url,omitempty"`
	Method          string        `json:"method,omitempty"`
	HeaderNames     []string      `json:"header_names,omitempty"`
	Expect          []StatusRange `json:"expect,omitempty"`
	Contains        string        `json:"contains,omitempty"`
	FollowRedirects bool          `json:"follow_redirects,omitempty"`
	Host            string        `json:"host,omitempty"`
	Port            int           `json:"port,omitempty"`
	// StatusLink opts the monitor in to opening and resolving a status page incident. Zero
	// confirm and recovery values fall back to the APP_MONITOR_LINK_* settings.
	StatusLink          bool `json:"status_link,omitempty"`
	LinkConfirmFailures int  `json:"link_confirm_failures,omitempty"`
	LinkRecoverySeconds int  `json:"link_recovery_seconds,omitempty"`
	// GraceSeconds is the heartbeat grace period; zero uses APP_MONITOR_HEARTBEAT_GRACE.
	GraceSeconds int `json:"grace_seconds,omitempty"`
	// WarnDays and CritDays override the APP_MONITOR_TLS_* thresholds for one TLS monitor.
	WarnDays int `json:"warn_days,omitempty"`
	CritDays int `json:"crit_days,omitempty"`
}

type Status struct {
	State         string
	FailStreak    int
	SuccessStreak int
}

type StatusLink struct {
	Enabled         bool
	ConfirmFailures int
	RecoverySeconds int
}

type StatusRange struct {
	Min int `json:"min"`
	Max int `json:"max"`
}

type Store interface {
	ResultSink
	ListMonitors(ctx context.Context) ([]Monitor, error)
	GetMonitor(ctx context.Context, id string) (Monitor, error)
	CountMonitors(ctx context.Context) (int, error)
	SaveMonitor(ctx context.Context, m Monitor) error
	DeleteMonitor(ctx context.Context, id string) error
	ListResults(ctx context.Context, id string, since int64, limit int) ([]Result, error)
	ListRollups(ctx context.Context, id string, sinceBucket int64, limit int) ([]Rollup, error)
	PruneResults(ctx context.Context, id string, before int64, limit int) (int, error)
	PruneRollups(ctx context.Context, id string, before int64, limit int) (int, error)
}

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

type Transition struct {
	Monitor Monitor
	State   string
	Reason  string
}