Struct IncrementalSlidingWindow 

pub struct IncrementalSlidingWindow { /* private fields */ }

A sliding window optimized for aggregations with O(1) updates

Instead of recomputing aggregations over all events on each emit, this window maintains running totals that are updated incrementally:

• Adding an event: O(1) update to aggregates
• Removing expired events: O(k) where k is expired count
• Getting aggregates: O(1)

This is ~10-100x faster than recomputing for large windows.

Implementations

impl IncrementalSlidingWindow

pub fn new( window_size: Duration, slide_interval: Duration, field: impl Into<String>, ) -> Self

Create a new incremental sliding window

pub fn add(&mut self, event: SharedEvent) -> Option<IncrementalAggregates>

Add an event, returning aggregates if slide interval reached

pub fn current_aggregates(&mut self) -> IncrementalAggregates

Get current aggregates without emitting

pub fn events(&self) -> impl Iterator<Item = &SharedEvent>

Get events in the current window (for patterns that need event access)

pub fn reset(&mut self)

Reset the window

Trait Implementations

impl Debug for IncrementalSlidingWindow

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

Formats the value using the given formatter.