Struct RunHistoryReplay 

pub struct RunHistoryReplay { /* private fields */ }

Incremental two-pass replay. First fold every fact; then read model events only after the latest successful summary. No persisted checkpoint is created.

Implementations

impl RunHistoryReplay

pub fn new(run_id: RunId) -> Self

Start reducing a Run from the first Session event.

pub fn facts(&mut self, events: &[SessionEvent]) -> Result<(), RuntimeError>

Validate and fold one bounded page of complete durable facts in order.

pub fn begin_model_tail(&mut self) -> u64

Freeze the first pass and return the exclusive cursor for the model tail.

pub fn model_tail( &mut self, events: &[SessionEvent], ) -> Result<(), RuntimeError>

Fold subsequent model events through the exact first-pass upper boundary.

pub fn finish(self) -> Result<RunHistory, RuntimeError>

Finish only when the model pass reaches the validated facts’ upper boundary.