Struct NetRouter 

pub struct NetRouter { /* private fields */ }

Net Router

Implementations

impl NetRouter

pub async fn new(config: RouterConfig) -> Result<Self>

Create a new router

pub fn set_test_drop_every_n(&self, n: u64)

Test-only: drop every nth dequeued (scheduled) packet in the send loop to simulate link loss. 0 disables. Used by reliability / retransmit tests; has no effect on the default (0) path.

pub fn local_addr(&self) -> Result<SocketAddr>

Get local address

pub fn routing_table(&self) -> &Arc<RoutingTable>

Get routing table

pub fn scheduler(&self) -> &Arc<FairScheduler>

Get the fair scheduler. Exposed so MeshNode::open_stream can propagate a stream’s fairness_weight to the forwarding path.

pub fn add_route(&self, dest_id: u64, next_hop: SocketAddr)

Add a route

pub fn remove_route(&self, dest_id: u64)

Remove a route

pub fn route_packet( &self, data: Bytes, _from: SocketAddr, ) -> Result<RouteAction, RouterError>

Route a packet (called from receive loop)

pub async fn send_to(&self, data: &[u8], dest: SocketAddr) -> Result<usize>

Send a packet directly (bypassing routing)

pub async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)>

Receive a packet

pub fn start(&self) -> Option<JoinHandle<()>>

Start the router (spawns send loop). Returns None if a dispatch loop is already running for this router; calling twice would otherwise spawn a second loop racing the first one’s scheduler.dequeue(), producing reordered or duplicate sends.

pub fn stop(&self)

Stop the router

pub fn is_running(&self) -> bool

Check if running

pub fn stats(&self) -> RouterStats

Get statistics

pub fn reset_stats(&self)

Reset statistics