Struct InProcessClusterTransport 

pub struct InProcessClusterTransport { /* private fields */ }

Channel-backed cluster transport. Discovers peers through a shared InProcessRegistry. Construct one per node, register the daemon’s gossip inbox + a RemoteMessageSink via Self::start, and call Self::send_remote to push remote-tells.

Implementations

impl InProcessClusterTransport

pub fn new(self_addr: Address, registry: Arc<InProcessRegistry>) -> Self

pub fn self_address(&self) -> &Address

pub fn send_remote( &self, target: &Address, target_path: String, manifest: String, payload: Vec<u8>, sender_path: Option<String>, )

Send a RemoteTell frame to target. Drops silently if the peer is not registered — matches the best-effort semantics of GossipTransport::send.

pub fn start( &self, gossip_inbox: UnboundedSender<GossipPdu>, sink: Arc<dyn RemoteMessageSink>, )

Spawn the inbound demultiplex task. gossip_inbox is the daemon’s crate::ClusterDaemonHandle::gossip_inbox sender; sink receives RemoteTell frames.

Trait Implementations

impl Drop for InProcessClusterTransport

fn drop(&mut self)

Executes the destructor for this type.

impl GossipTransport for InProcessClusterTransport

fn send(&self, target: &Address, pdu: GossipPdu)

Deliver pdu to target. The transport is “best effort” — errors must not crash the daemon.