Struct StateAggregator 

pub struct StateAggregator { /* private fields */ }

High-level aggregator built on top of DistributedStateStore.

Provides common streaming aggregation patterns: increment counters, running float sums, gauges, and windowed event counts.

Implementations

impl StateAggregator

pub fn new(partition_count: u32) -> Self

Create an aggregator backed by a store with partition_count partitions.

pub fn increment(&mut self, key: &str, by: i64) -> i64

Increment an integer counter by by. Returns the updated value.

pub fn accumulate(&mut self, key: &str, value: f64) -> f64

Add value to a running float sum. Returns the updated sum.

pub fn update_gauge(&mut self, key: &str, value: f64)

Update a gauge value (timestamped float).

pub fn window_count(&mut self, window_key: &str, event_key: &str) -> u64

Count events within a named window. Uses a composite key window_key:event_key. Returns the updated count.

pub fn merge_from(&mut self, other: &DistributedStateStore)

Merge all state from other store into this aggregator’s store.

pub fn store(&self) -> &DistributedStateStore

Read-only access to the underlying store.