Struct Resolver 

pub struct Resolver { /* private fields */ }

Single durability chokepoint that resolves workflow commands against recorded history.

Implementations

impl Resolver

pub const fn new(workflow_id: WorkflowId, cursor: HistoryCursor) -> Self

Creates a resolver for one workflow history.

The workflow id is retained for typed non-determinism diagnostics; AD-006 wires the determinism-context timestamp hook at this same chokepoint.

pub fn history(&self) -> &[Event]

Returns the ordered history snapshot backing this resolver.

pub fn resolve( &mut self, command: Command, ) -> Result<ResolveOutcome, DurabilityError>

Resolves a command from recorded history or returns ResolveOutcome::ResumeLive.

Errors

Returns DurabilityError::NonDeterminism when the cursor reports a command-stream mismatch, or DurabilityError::HistoryShape when matched history lacks one of AD-004’s recorded terminal outcomes.

pub fn next_command_ordinal(&self, family: RecordedEventFamily) -> Option<u64>

Returns the correlation ordinal at the current replay cursor for the requested family.

pub fn fast_forward_to(&mut self, key: &CorrelationKey)

Advance the cursor past commands consumed by earlier resolver instances of the same live execution. See HistoryCursor::fast_forward_to_key.

pub fn fast_forward_to_child_terminal(&mut self, child_workflow_id: &WorkflowId)

Advance the cursor to the recorded terminal outcome for one awaited child workflow. See HistoryCursor::fast_forward_to_child_terminal.

pub fn resolve_with_consumed( &mut self, command: Command, ) -> Result<ResolvedCommand, DurabilityError>

Resolves a command and includes the consumed recorded timestamp for replay bookkeeping.

The returned ResolvedCommand preserves the existing recorded/resume-live decision while exposing the timestamp of the last consumed history event. Replay uses that timestamp as the only source for advancing workflow-visible now.

Errors

Returns DurabilityError::NonDeterminism when the cursor reports a command-stream mismatch, or DurabilityError::HistoryShape when matched history lacks one of AD-004’s recorded terminal outcomes.

Trait Implementations

impl Clone for Resolver

fn clone(&self) -> Resolver

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Resolver

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

Formats the value using the given formatter.