Struct NetworkManager 

pub struct NetworkManager { /* private fields */ }

The user-facing API for the networking stack.

NetworkManager ties together all five layers (identity, transport, routing, discovery, application) and provides a simple interface for sending messages, discovering peers, and subscribing to network events.

Example

let manager = NetworkManagerBuilder::new(my_identity)
    .add_transport(IpcTransport::new(None))
    .with_discovery(ManualDiscovery::new())
    .build();

manager.send(peer_id, "hello").await?;

let mut events = manager.subscribe();
while let Ok(event) = events.recv().await {
    // handle events
}

Implementations

impl NetworkManager

pub fn identity(&self) -> &AgentIdentity

Get this agent’s identity.

pub fn subscribe(&self) -> Receiver<NetworkEvent>

Subscribe to network events.

pub async fn peer_table(&self) -> RwLockReadGuard<'_, PeerTable>

Get a read lock on the peer table.

pub async fn peer_table_mut(&self) -> RwLockWriteGuard<'_, PeerTable>

Get a write lock on the peer table.

pub async fn peers(&self) -> Vec<AgentIdentity>

List all known peers.

pub async fn send( &self, target: Uuid, payload: impl Into<Payload>, ) -> Result<()>

Send a message to a specific peer.

pub async fn broadcast(&self, payload: impl Into<Payload>) -> Result<()>

Broadcast a message to all known peers.

pub async fn publish( &self, topic: impl Into<String>, payload: impl Into<Payload>, ) -> Result<()>

Publish a message to a topic.

pub async fn send_envelope(&self, envelope: MessageEnvelope) -> Result<()>

Send a pre-built envelope.

pub fn add_transport(&mut self, transport: Box<dyn Transport>)

Add a transport to the manager.

pub fn set_custom_router(&mut self, router: Box<dyn Router>)

Set a custom router (overrides the default direct router for point-to-point messages).

pub fn add_discovery(&mut self, discovery: Box<dyn Discovery>)

Add a discovery service.

pub async fn register_self(&self) -> Result<()>

Register this agent with all discovery services.

pub async fn deregister_self(&self) -> Result<()>

Deregister this agent from all discovery services.

pub async fn discover_peers(&self) -> Result<Vec<AgentIdentity>>

Run discovery across all services and update the peer table.

pub fn emit(&self, event: NetworkEvent)

Emit a network event.