Struct PartitionedSessionWindow 

pub struct PartitionedSessionWindow { /* private fields */ }

A partitioned session window that maintains separate sessions per partition key

Implementations

impl PartitionedSessionWindow

pub fn new(partition_key: String, gap: Duration) -> Self

pub fn add_shared(&mut self, event: SharedEvent) -> Option<Vec<SharedEvent>>

Add a shared event to the appropriate partition session.

pub fn add(&mut self, event: Event) -> Option<Vec<Event>>

Add an event (wraps in Arc).

pub fn check_expired( &mut self, now: DateTime<Utc>, ) -> Vec<(String, Vec<SharedEvent>)>

Check all partitions for expired sessions. Returns a list of (partition_key, events) for each expired session, and removes those partitions from the map.

pub const fn gap(&self) -> Duration

Get the configured gap duration.

pub fn flush_shared(&mut self) -> Vec<SharedEvent>

Flush all partition sessions as SharedEvent references.

pub fn flush(&mut self) -> Vec<Event>

Flush all partition sessions (clones for backward compatibility).

pub fn checkpoint(&self) -> WindowCheckpoint

Create a checkpoint of all partition sessions.

pub fn restore(&mut self, cp: &WindowCheckpoint)

Restore partition sessions from a checkpoint.

pub fn advance_watermark( &mut self, wm: DateTime<Utc>, ) -> Vec<(String, Vec<SharedEvent>)>

Advance watermark — close expired sessions across all partitions.

Trait Implementations

impl Debug for PartitionedSessionWindow

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

Formats the value using the given formatter.