Struct SessionWindowProcessor 

pub struct SessionWindowProcessor<T: Clone> { /* private fields */ }

Stateful processor that groups a time-ordered event stream into session windows.

Call Self::process for each incoming event (events must arrive in non-decreasing timestamp order). Call Self::flush at end-of-stream to close any pending session. Completed windows are collected via Self::drain_sessions.

Implementations

impl<T: Clone> SessionWindowProcessor<T>

pub fn new(config: SessionWindowConfig) -> Self

Create a new processor with the given configuration.

pub fn process(&mut self, event: StreamEvent<T>) -> Result<(), StreamingError>

Process an incoming event.

A new session is started if:

• There is no open session, or
• The gap since the previous event exceeds gap_duration, or
• The current session has exceeded max_session_duration.

pub fn flush(&mut self)

Force-close the currently open session (call at end of stream).

After flushing, any sessions that meet the min_events threshold are available via Self::drain_sessions.

pub fn drain_sessions(&mut self) -> Vec<SessionWindow<T>>

Drain and return all completed session windows.

The internal buffer is cleared; subsequent calls return an empty Vec until more sessions are closed.

pub fn pending_event_count(&self) -> usize

Number of events buffered in the currently open (not yet closed) session.

pub fn total_sessions_closed(&self) -> u64

Total number of sessions that have been closed (includes discarded ones).