telemetry

type Aggregator struct {
	Sources []Source
	// Rules, when non-empty, are evaluated against every Snapshot. The
	// list is validated by Aggregator.WithAlerts; assigning Rules
	// directly skips that check.
	Rules []AlertRule
}

type AlertRule struct {
	// Name is a stable identifier used in JSON output, Prometheus
	// labels, and operator runbooks. Must be unique within the rule
	// list; duplicates are rejected by ValidateAlertRules.
	Name string `json:"name"`
	// Severity classifies the firing. See Severity for the levels.
	Severity Severity `json:"severity"`
	// Description is the operator-facing one-liner explaining what the
	// rule guards against. Shown in dashboards next to the firing
	// state.
	Description string `json:"description,omitempty"`
	// Condition returns true when the rule should fire for snap.
	Condition func(snap Snapshot) bool `json:"-"`
}

type CacheSource struct {
	Stats func() cacheStats
	// contains filtered or unexported fields
}

type CacheStats struct {
	HitRatePct        float64 `json:"hit_rate_pct"`
	SizeBytes         int64   `json:"size_bytes"`
	SizeEntries       int64   `json:"size_entries,omitempty"`
	EvictionsLastHour int64   `json:"evictions_last_hour"`
}

type CacheStatter interface {
	Stats() cacheStats
}

type ChannelEntry struct {
	Name    string
	Pattern string
}

type ChannelLister interface {
	List() []ChannelEntry
}

type ChannelSource struct{ Lister ChannelLister }

type ChannelStats struct {
	TotalActive int64            `json:"total_active"`
	ByPattern   map[string]int64 `json:"by_pattern,omitempty"`
}

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

type EnvelopeStats struct {
	RatePerSecond float64          `json:"rate_per_second"`
	ByAspect      map[string]int64 `json:"by_aspect,omitempty"`
}

type FiringAlert struct {
	Name        string   `json:"name"`
	Severity    Severity `json:"severity"`
	Description string   `json:"description,omitempty"`
}

type HistoryStats struct {
	TotalEnvelopesBuffered int64   `json:"total_envelopes_buffered"`
	BufferUtilizationPct   float64 `json:"buffer_utilization_pct"`
}

type PresenceStats struct {
	TotalUsers        int64   `json:"total_users"`
	TotalAgents       int64   `json:"total_agents"`
	AveragePerChannel float64 `json:"average_per_channel"`
}

type Severity string

type Snapshot struct {
	Channels  ChannelStats  `json:"channels"`
	Envelopes EnvelopeStats `json:"envelopes"`
	Presence  PresenceStats `json:"presence"`
	History   HistoryStats  `json:"history"`
	Tokens    TokenStats    `json:"tokens"`
	Cache     CacheStats    `json:"cache"`
	At        time.Time     `json:"at"`
	// Alerts lists the AlertRule(s) that evaluated true on this snapshot.
	// Empty when no rules are configured or none fired. Populated by the
	// Aggregator after summing sources so a rule can reference the
	// aggregate (e.g. "total active > N").
	Alerts []FiringAlert `json:"alerts,omitempty"`
}

type Source interface {
	Channels(ctx context.Context) ChannelStats
	Envelopes(ctx context.Context) EnvelopeStats
	Presence(ctx context.Context) PresenceStats
	History(ctx context.Context) HistoryStats
	Tokens(ctx context.Context) TokenStats
	Cache(ctx context.Context) CacheStats
}

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

type TokenStats struct {
	IssuedLastHour  int64 `json:"issued_last_hour"`
	RevokedLastHour int64 `json:"revoked_last_hour"`
	ActiveCount     int64 `json:"active_count"`
}