telemetry

type Aggregator struct {
	Sources []Source
}

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 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 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"`
}

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"`
}