Struct WindowConfig 

pub struct WindowConfig {
    pub window_type: WindowType,
    pub duration: Duration,
    pub max_events: usize,
}

Window configuration for stream processing

Fields

window_type: WindowType

duration: Duration

max_events: usize

Implementations

impl WindowConfig

pub fn sliding(duration: Duration) -> Self

Create a sliding window configuration

pub fn tumbling(duration: Duration) -> Self

Create a tumbling window configuration

pub fn session(timeout: Duration) -> Self

Create a session window configuration

pub fn with_max_events(self, max_events: usize) -> Self

Set maximum events per window

Trait Implementations

impl Clone for WindowConfig

fn clone(&self) -> WindowConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WindowConfig

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

Formats the value using the given formatter.