Struct ReplayEffectHandler 

pub struct ReplayEffectHandler<'a> { /* private fields */ }

A replay-mode handler that serves recorded effect outcomes in order.

Implementations

impl<'a> ReplayEffectHandler<'a>

pub fn new<E>(entries: E) -> Self

where E: Into<Arc<[EffectTraceEntry]>>,

Build a replay handler without fallback behavior.

pub fn with_fallback<E>(entries: E, fallback: &'a dyn EffectHandler) -> Self

where E: Into<Arc<[EffectTraceEntry]>>,

Build a replay handler with fallback behavior for unsupported entries.

pub fn remaining(&self) -> usize

Number of unconsumed entries.

Panics

Panics if the internal mutex is poisoned.

Trait Implementations

impl EffectHandler for ReplayEffectHandler<'_>

fn handler_identity(&self) -> String

Stable identifier for effect-trace attribution.

fn handle_effect(&self, request: EffectRequest) -> EffectOutcome

Canonical typed effect boundary for guest-runtime execution.

fn handle_send( &self, role: &str, partner: &str, label: &str, state: &[Value], ) -> EffectResult<Value>

Compute the payload for a send instruction.

fn send_decision( &self, input: SendDecisionInput<'_>, ) -> EffectResult<SendDecision>

Decide how to handle a send, optionally with a precomputed payload.

fn handle_recv( &self, role: &str, partner: &str, label: &str, state: &mut Vec<Value>, payload: &Value, ) -> EffectResult<()>

Process a received value.

fn handle_choose( &self, role: &str, partner: &str, labels: &[String], state: &[Value], ) -> EffectResult<String>

Choose which branch to take for internal choice (select).

fn step(&self, role: &str, state: &mut Vec<Value>) -> EffectResult<()>

Perform an integration step after a protocol round.

fn handle_acquire( &self, sid: SessionId, role: &str, layer: &str, state: &[Value], ) -> EffectResult<Value>

Attempt to acquire a guard layer.

fn handle_release( &self, sid: SessionId, role: &str, layer: &str, evidence: &Value, state: &[Value], ) -> EffectResult<()>

Release a guard layer using previously acquired evidence.

fn topology_events(&self, tick: u64) -> EffectResult<Vec<TopologyPerturbation>>

Topology perturbations injected by the environment for this scheduler tick.

fn output_condition_hint( &self, sid: SessionId, role: &str, state: &[Value], ) -> Option<OutputConditionHint>

Optional output-condition metadata for commit gating.

fn supports_wal_sync(&self) -> bool

Whether this handler can service the internal wal_sync effect.

fn wal_sync(&self, sync: &WalSyncRequest) -> EffectResult<()>

Confirm that the agreement WAL has been durably synchronized.