Struct NestedProtocolMachineHandler 

pub struct NestedProtocolMachineHandler { /* private fields */ }

Effect handler that dispatches to inner ProtocolMachines keyed by outer role name.

Implementations

impl NestedProtocolMachineHandler

pub fn new() -> Self

Create an empty nested handler.

pub fn with_rounds_per_step(self, rounds: usize) -> Self

Set how many inner ProtocolMachine rounds to advance per outer handler call.

pub fn rounds_per_step(&self) -> usize

Number of inner ProtocolMachine rounds attempted per outer handler call.

pub fn add_site( &mut self, name: impl Into<String>, machine: ProtocolMachine, handler: Box<dyn EffectHandler>, )

Register a site by name with its inner ProtocolMachine and handler.

pub fn site_trace(&self, name: &str) -> Option<Vec<ObsEvent>>

Get a copy of the inner ProtocolMachine trace for a site.

Panics

Panics if the site ProtocolMachine mutex is poisoned.

pub fn site_all_done(&self, name: &str) -> Option<bool>

Check whether all coroutines in a site ProtocolMachine are terminal.

Panics

Panics if the site ProtocolMachine mutex is poisoned.

pub fn site_semantic_objects( &self, name: &str, ) -> Option<ProtocolMachineSemanticObjects>

Get a copy of the canonical semantic-object bundle for a site.

Panics

Panics if the site ProtocolMachine mutex is poisoned.

Trait Implementations

impl Default for NestedProtocolMachineHandler

fn default() -> Self

Returns the “default value” for a type.

impl EffectHandler for NestedProtocolMachineHandler

fn handle_send( &self, role: &str, _partner: &str, _label: &str, _state: &[Value], ) -> EffectResult<Value>

Compute the payload for a send instruction.

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 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 send_decision( &self, input: SendDecisionInput<'_>, ) -> EffectResult<SendDecision>

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

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.