Struct MeshService 

pub struct MeshService { /* private fields */ }

A handle to a running mesh: sole owner of the inbound packet stream and the thread’s join handle, plus a MeshControl. Clone control for additional control handles; the inbound receiver stays single-owner (only the mesh’s consumer — e.g. the chat loop — drains it).

Implementations

impl MeshService

pub fn spawn(mesh: SocialWebNet) -> MeshService

Spawn the mesh thread, taking ownership of an already-constructed SocialWebNet (peers may be pre-added or added later via add_peer).

pub fn control(&self) -> MeshControl

A cloneable control handle to this mesh — share it with a status UI, a chat loop, etc. All control handles and the MeshService itself drive the same mesh thread.

pub fn add_peer( &self, peer_id: &str, peer_pubkey_hex: &str, endpoint: Option<SocketAddr>, ) -> Result<SocketAddr, String>

Add a peer; returns the local socket address the tunnel bound (advertise it to the peer).

pub fn set_peer_endpoint( &self, peer_id: &str, addr: SocketAddr, ) -> Result<(), String>

Point a peer’s tunnel at addr.

pub fn initiate_handshake(&self, peer_id: &str) -> Result<(), String>

Start the handshake with a peer (initiator side; endpoint must be set).

pub fn send(&self, peer_id: &str, inner: Vec<u8>) -> Result<bool, String>

Encrypt and send one inner IPv6 packet to a peer.

pub fn remove_peer(&self, peer_id: &str) -> Result<bool, String>

Remove a peer; returns whether it was present.

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

The peer ids currently in the mesh.

pub fn has_session(&self, peer_id: &str) -> Result<bool, String>

Whether a live session exists with a peer.

pub fn try_recv(&self) -> Option<MeshPacket>

Non-blocking receive of the next inbound inner packet, if any.

pub fn recv_timeout(&self, timeout: Duration) -> Option<MeshPacket>

Block up to timeout for the next inbound inner packet.

pub fn wait_for_session(&self, peer_id: &str, timeout: Duration) -> bool

Poll until a session is established with peer_id, or timeout elapses. Returns whether the session came up.

pub fn shutdown(&mut self)

Stop the mesh thread and join it. Called automatically on drop.

Trait Implementations

impl Drop for MeshService

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.