Struct SessionReducer 

pub struct SessionReducer { /* private fields */ }

Pure deterministic reducer for canonical durable session records.

Implementations

impl SessionReducer

pub const fn new() -> Self

Creates an empty reducer awaiting a sequence-zero creation record.

pub fn replay( records: impl IntoIterator<Item = RecordEnvelope>, ) -> Result<MaterializedSessionState, SessionReplayError>

Rebuilds materialized state from canonical record order.

Errors

Returns a deterministic corruption/reference/transition error when the complete record stream cannot represent one valid session.

pub fn replay_reducer( records: impl IntoIterator<Item = RecordEnvelope>, ) -> Result<Self, SessionReplayError>

Rebuilds a reusable reducer from canonical record order.

Errors

Returns the first deterministic replay failure.

pub fn apply( &mut self, envelope: &RecordEnvelope, ) -> Result<(), SessionReplayError>

Applies one next canonical record atomically to this reducer.

Errors

Returns an error without changing reducer state when sequence, identity, reference, or lifecycle invariants fail.

pub const fn state(&self) -> Option<&MaterializedSessionState>

Returns current materialized state, or None before creation.

Trait Implementations

impl Clone for SessionReducer

fn clone(&self) -> SessionReducer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SessionReducer

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

Formats the value using the given formatter.

impl Default for SessionReducer

fn default() -> SessionReducer

Returns the “default value” for a type.