Struct Manager 

pub struct Manager<K, V>
where
    K: Eq + Hash + Clone,
    V: Clone + Send + Sync + 'static,
{ /* private fields */ }

Manages per-key accumulators and TTL cleanup.

Implementations

impl<K, V> Manager<K, V>

where K: Eq + Hash + Clone, V: Clone + Send + Sync + 'static,

pub fn new( config: AccumulatorConfig<V>, store_factory: impl Fn() -> Box<dyn Store<V>> + Send + Sync + 'static, ) -> Self

Create a new keyed manager.

pub fn get_or_create(&self, key: K) -> Arc<Accumulator<V>>

Get the accumulator for key, creating it when missing.

pub fn append(&self, key: K, value: V) -> AppResult<Option<Vec<V>>>

Append a value to the keyed accumulator.

pub fn flush(&self, key: &K) -> AppResult<Option<Vec<V>>>

Flush a keyed accumulator.

pub fn size(&self, key: &K) -> AppResult<usize>

Return the buffered size for key.

pub fn keys(&self) -> Vec<K>

List all currently active keys.

pub fn cleanup_expired(&self) -> AppResult<Vec<K>>

Remove expired accumulators and return the removed keys.