Struct SlidingWindow 

pub struct SlidingWindow { /* private fields */ }

A sliding window that maintains overlapping windows

Implementations

impl SlidingWindow

pub const fn new(window_size: Duration, slide_interval: Duration) -> Self

pub fn add_shared(&mut self, event: SharedEvent) -> Option<Vec<SharedEvent>>

Add a shared event, returning window contents if slide interval reached.

pub fn add(&mut self, event: Event) -> Option<Vec<Event>>

Add an event (wraps in Arc).

pub fn current_shared(&self) -> Vec<SharedEvent>

Get current window contents as shared references.

pub fn current(&self) -> Vec<Event>

Get current window contents (clones for backward compatibility).

pub fn checkpoint(&self) -> WindowCheckpoint

Create a checkpoint of the current window state.

pub fn restore(&mut self, cp: &WindowCheckpoint)

Restore window state from a checkpoint.

pub fn advance_watermark( &mut self, wm: DateTime<Utc>, ) -> Option<Vec<SharedEvent>>

Advance watermark — emit window if slide interval has passed relative to watermark.

Trait Implementations

impl Debug for SlidingWindow

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

Formats the value using the given formatter.