Struct RuntimePeerCommsHandle 

pub struct RuntimePeerCommsHandle { /* private fields */ }

Runtime-backed PeerCommsHandle impl.

Routes every trait method to the corresponding DSL signal / input on a dedicated per-session MeerkatMachine DSL authority.

Implementations

impl RuntimePeerCommsHandle

pub fn new(dsl: Arc<HandleDslAuthority>) -> Self

Construct a handle backed by the session’s shared DSL authority.

pub fn install_generated_on( dsl: Arc<HandleDslAuthority>, target: &(dyn PeerCommsInstallTarget + '_), ) -> Result<(), String>

Install a generated peer-comms handle and its matching trust owner.

The owner token stays on the generated install path; callers receive no reusable token that could be copied into a handwritten handle.

pub fn ephemeral() -> Self

Construct a handle backed by an ephemeral DSL authority.

See [RuntimeTurnStateHandle::ephemeral].

Trait Implementations

impl Debug for RuntimePeerCommsHandle

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

Formats the value using the given formatter.

impl PeerCommsHandle for RuntimePeerCommsHandle

fn classify_external_envelope( &self, facts: PeerIngressEnvelopeFacts, ) -> Result<PeerIngressAdmission, DslTransitionError>

Fire the ClassifyExternalEnvelope signal and return machine-owned admission facts for the parsed envelope.

fn classify_plain_event( &self, facts: PeerIngressPlainEventFacts, ) -> Result<PeerIngressAdmission, DslTransitionError>

Fire the ClassifyPlainEvent signal and return machine-owned admission facts for the parsed plain event.

fn resolve_peer_ingress_receive( &self, facts: PeerIngressReceiveFacts, ) -> Result<PeerIngressReceiveAuthority, DslTransitionError>

Fire ResolvePeerIngressReceive and return the machine-owned admission outcome plus authority phase for a classified peer envelope.

fn resolve_peer_ingress_dequeue( &self, facts: PeerIngressDequeueFacts, ) -> Result<PeerIngressDequeueAuthority, DslTransitionError>

Fire ResolvePeerIngressDequeue and return the machine-owned authority phase for a classified queue dequeue observation.

fn set_peer_ingress_context( &self, keep_alive: bool, ) -> Result<(), DslTransitionError>

Fire the SetPeerIngressContext { keep_alive } input.

fn install_generated_peer_comms_on_target( &self, expected_owner: &GeneratedPeerCommsOwnerToken, target: &(dyn PeerCommsInstallTarget + '_), ) -> Result<(), String>

Route a local-runtime endpoint observation through generated machine authority and install the accepted generated authority package on the target.