Struct ReplayReducer 

pub struct ReplayReducer { /* private fields */ }

Holds replay reducer application-layer state or configuration. Use it with the documented coordinator methods; run, journal, event, provider, or port effects are called out on those methods rather than on construction.

Implementations

impl ReplayReducer

pub fn new(mode: ReplayMode) -> Self

Creates a new application::replay value with explicit caller-provided inputs. This constructor is data-only and performs no I/O or external side effects.

pub fn with_available_content_refs( self, refs: impl IntoIterator<Item = ContentRef>, ) -> Self

Returns this value with its available content refs setting replaced. The method follows builder-style data construction and does not execute external work.

pub fn with_missing_content_policy(self, policy: MissingContentPolicy) -> Self

Returns this value with its missing content policy setting replaced. The method follows builder-style data construction and does not execute external work.

pub fn apply(&mut self, record: JournalRecord) -> Result<(), AgentError>

Apply. This mutates only the replay projection with one journal record and never re-executes the recorded side effect.

pub fn finish(self) -> Result<ReplayResult, AgentError>

Finish. This finalizes replay bookkeeping into a result and does not re-execute recorded effects.

Trait Implementations

impl Clone for ReplayReducer

fn clone(&self) -> ReplayReducer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReplayReducer

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

Formats the value using the given formatter.