Struct WindowManager 

pub struct WindowManager { /* private fields */ }

Manages multiple time windows for stream processing

Implementations

impl WindowManager

pub fn new( window_type: WindowType, duration: Duration, max_events_per_window: usize, max_windows: usize, ) -> Self

Create a new window manager

pub fn process_event(&mut self, event: StreamEvent)

Process a new event through the window system

pub fn active_windows(&self) -> &[TimeWindow]

Get all active windows

pub fn latest_window(&self) -> Option<&TimeWindow>

Get the latest window

pub fn total_event_count(&self) -> usize

Get total event count across all windows

pub fn windows_with_event_type(&self, event_type: &str) -> Vec<&TimeWindow>

Get windows that contain events of a specific type

pub fn aggregate_across_windows<F>(&self, aggregator: F) -> f64

where F: Fn(&TimeWindow) -> f64,

Calculate aggregate across all windows

pub fn get_statistics(&self) -> WindowStatistics

Get window statistics

Trait Implementations

impl Debug for WindowManager

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

Formats the value using the given formatter.