monitor

type AlertRule struct {
	// Name identifies the rule in alert payloads and logs.
	Name string
	// Condition returns true when the alert should fire.
	Condition func(stats *Stats) bool
	// Message produces the human-readable alert body from current stats.
	Message func(stats *Stats) string
	// Cooldown is the minimum duration between successive fires of this rule.
	// A zero value means no cooldown (fire on every Check).
	Cooldown time.Duration
	// contains filtered or unexported fields
}

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

type DomainSnapshot struct {
	Requests   int64
	Errors     int64
	Blocked    int64
	AvgLatency time.Duration
}

type LogSink struct{}

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

type Stats struct {
	// StartedAt is set when NewStats is called and used for rate calculations.
	StartedAt time.Time

	// Request counters.
	Requests atomic.Int64
	Success  atomic.Int64
	Errors   atomic.Int64
	Blocked  atomic.Int64
	Bytes    atomic.Int64

	// Pipeline / crawler counters.
	Items        atomic.Int64
	Escalations  atomic.Int64
	CacheHits    atomic.Int64
	CacheMisses  atomic.Int64
	DedupSkipped atomic.Int64
	RetryCount   atomic.Int64
}

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

type StatsSink interface {
	Record(snapshot StatsSnapshot)
}

type StatsSnapshot struct {
	Requests    int64
	Success     int64
	Errors      int64
	Blocked     int64
	Items       int64
	Escalations int64
	Bytes       int64
	Domains     map[string]DomainSnapshot
}

type StatsSource interface {
	Snapshot() StatsSnapshot
}