Struct ReplayCursor 

pub struct ReplayCursor { /* private fields */ }

Dispatcher-side read helper: an in-memory index of the entries loaded from a ReplayStore for one Run, plus the per-(step_ref, input_hash) occurrence counter the dispatcher bumps at each call.

next_occurrence and find are the two operations the dispatcher performs per attempt: the former advances the counter and returns the current occurrence value, the latter tries to resolve (step_ref, input_hash, occurrence) against the loaded entries.

Implementations

impl ReplayCursor

pub fn from_entries(entries: Vec<ReplayEntry>) -> Self

Build a cursor from a run’s worth of entries. Entries whose step_output_json fails to decode are silently skipped after a tracing::warn! — a corrupt row must not prevent the rest of the run from replaying.

pub fn next_occurrence(&mut self, step_ref: &str, input_hash: &str) -> u32

Advance the occurrence counter for (step_ref, input_hash) and return the value for THIS call (0 on the first call, 1 on the second, and so on). Consumes one occurrence: two consecutive calls with the same key return 0 then 1.

pub fn find( &self, step_ref: &str, input_hash: &str, occurrence: u32, ) -> Option<Value>

Look up a stored DispatchOutcome::Pass value by (step_ref, input_hash, occurrence). None = miss (no matching row was appended for this triple).

pub fn len(&self) -> usize

Number of (step_ref, input_hash, occurrence) entries loaded. Handy for tests / diagnostics.

pub fn is_empty(&self) -> bool

true when no entries are loaded — every find will miss.

Trait Implementations

impl Debug for ReplayCursor

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

Formats the value using the given formatter.

impl Default for ReplayCursor

fn default() -> ReplayCursor

Returns the “default value” for a type.