Struct StatsAggregator 

pub struct StatsAggregator { /* private fields */ }

In-memory aggregator for batched daily stats updates.

During batch ingestion, we accumulate deltas per (day_id, agent, source) key. After processing all conversations, call expand() to generate the 4 permutations per raw entry, then flush via SqliteStorage::update_daily_stats_batched.

Example

let mut agg = StatsAggregator::new();
for conv in conversations {
    agg.record(&conv.agent_slug, source_id, day_id, msg_count, char_count);
}
let entries = agg.expand();
storage.update_daily_stats_batched(&entries)?;

Implementations

impl StatsAggregator

pub fn new() -> Self

Create a new empty aggregator.

pub fn record( &mut self, agent_slug: &str, source_id: &str, day_id: i64, message_count: i64, total_chars: i64, )

Record a conversation’s contribution to stats (session + messages + chars).

This increments session_count by 1.

Arguments

• agent_slug - The specific agent slug (not “all”)
• source_id - The specific source ID (not “all”)
• day_id - Days since 2020-01-01 (from SqliteStorage::day_id_from_millis)
• message_count - Number of messages in the conversation
• total_chars - Total character count across all messages

pub fn record_delta( &mut self, agent_slug: &str, source_id: &str, day_id: i64, session_count_delta: i64, message_count_delta: i64, total_chars_delta: i64, )

Record an arbitrary delta. Use this for append-only updates where session_count_delta may be 0 but message/char deltas are non-zero.

pub fn expand(&self) -> Vec<(i64, String, String, StatsDelta)>

Expand raw deltas into the 4 permutation keys:

• (agent, source) - specific both
• (“all”, source) - all agents, specific source
• (agent, “all”) - specific agent, all sources
• (“all”, “all”) - totals

Returns entries sorted by (day_id, agent_slug, source_id) for deterministic batching.

pub fn is_empty(&self) -> bool

Check if the aggregator is empty (no data recorded).

pub fn raw_entry_count(&self) -> usize

Get number of distinct raw (day, agent, source) combinations recorded.

Trait Implementations

impl Debug for StatsAggregator

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for StatsAggregator

fn default() -> StatsAggregator

Returns the “default value” for a type.