Struct ChatMeshBridge 

pub struct ChatMeshBridge { /* private fields */ }

Per-peer reliable chat routing over the mesh. One bridge per node; it holds a ReliableEndpoint per peer DID.

Implementations

impl ChatMeshBridge

pub fn new(rto_ms: u64, max_attempts: u32) -> ChatMeshBridge

A bridge with explicit reliability parameters (mostly for tests).

pub fn peers(&self) -> Vec<String>

Peers this bridge currently has a channel to.

pub fn broadcast( &mut self, peer_dids: &[String], env: &RelayEnvelope, now_ms: u64, ) -> Vec<OutFrame>

Reliably send env to every peer in peer_dids. The envelope is encoded once; each peer’s channel assigns its own sequence number. Returns the frames to send.

pub fn send_to( &mut self, peer_did: &str, env: &RelayEnvelope, now_ms: u64, ) -> OutFrame

Reliably send env to a single peer.

pub fn on_inbound( &mut self, peer_did: &str, frame: &[u8], now_ms: u64, ) -> InboundChat

Process one inbound reliable-channel frame from peer_did. Returns the ACK to send back and, if the frame completed a new envelope, the decoded RelayEnvelope to apply.

pub fn on_tick(&mut self, now_ms: u64) -> Vec<OutFrame>

Retransmit any unacknowledged frames whose RTO has elapsed, across all peers.

pub fn pending(&self) -> usize

Total frames still awaiting acknowledgement across all peers.

Trait Implementations

impl Default for ChatMeshBridge

fn default() -> Self

Returns the “default value” for a type.