Struct SessionWindow 

pub struct SessionWindow { /* private fields */ }

Session window (dynamic windows based on activity).

Implementations

impl SessionWindow

pub fn new(gap: Duration) -> Self

Create a new session window.

pub fn with_max_duration(gap: Duration, max_duration: Duration) -> Self

Create a new session window with maximum duration.

pub fn assign(&mut self, timestamp: DateTime<Utc>) -> Result<Window>

Assign an element to a session window.

pub fn active_sessions(&self) -> Vec<Window>

Get all active sessions.

pub fn clear_expired(&mut self, watermark: DateTime<Utc>)

Clear expired sessions.

Trait Implementations

impl Debug for SessionWindow

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

Formats the value using the given formatter.