Struct ReplayExecutor 

pub struct ReplayExecutor<L: ReplayLog, I: EffectInvoker> {
    pub log: L,
    pub invoker: I,
}

Fields

log: L

invoker: I

Implementations

impl<L: ReplayLog, I: EffectInvoker> ReplayExecutor<L, I>

pub fn new(log: L, invoker: I) -> Self

pub async fn replay_token( &self, token_hash_hex: &str, ) -> Result<ReplayOutcome, ReplayExecutorError>

Replay a single token; return the outcome.

pub async fn replay_flow( &self, flow_id: &str, ) -> Result<Vec<ReplayOutcome>, ReplayExecutorError>

Replay every token for a flow, short-circuiting at the first divergence. Adopters that prefer to collect every divergence can call Self::verify_token in a custom loop.

pub async fn verify_token( &self, token: &ReplayToken, ) -> Result<ReplayOutcome, EffectInvokerError>

Low-level — given a concrete token, re-invoke + compare.