Struct EvidencePersistenceHandler 

pub struct EvidencePersistenceHandler<'a, C, R>
where
    C: EvidenceOutcomeCache,
    R: EvidenceIdResolver,
{ /* private fields */ }

Effect-handler wrapper that persists agreement-relevant outcomes keyed by semantic evidence id.

Implementations

impl<'a, C, R> EvidencePersistenceHandler<'a, C, R>

where C: EvidenceOutcomeCache, R: EvidenceIdResolver,

pub fn new(inner: &'a dyn EffectHandler, cache: C, resolver: R) -> Self

Create one evidence-persistence wrapper around an inner handler.

pub fn cached_outcome( &self, evidence_id: &str, ) -> Result<Option<EffectOutcome>, String>

Load one cached outcome by evidence id.

Errors

Returns an error if the cache cannot be loaded.

pub fn cache_snapshot(&self) -> Result<EvidenceOutcomeCacheArtifact, String>

Load the full typed cache artifact.

Errors

Returns an error if the cache cannot be loaded.

Trait Implementations

impl<C, R> EffectHandler for EvidencePersistenceHandler<'_, C, R>

where C: EvidenceOutcomeCache + Send, R: EvidenceIdResolver,

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 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.

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.