Struct SlidingCountWindow 

pub struct SlidingCountWindow { /* private fields */ }

A sliding count window that maintains overlapping windows

Implementations

impl SlidingCountWindow

pub fn new(window_size: usize, slide_size: usize) -> 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_count(&self) -> usize

Get current count of events in buffer (for debugging)

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.

Trait Implementations

impl Debug for SlidingCountWindow

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

Formats the value using the given formatter.