Struct Router 

pub struct Router { /* private fields */ }

Production-ready multi-path router with advanced load balancing and dark addressing

Implementations

impl Router

pub fn new(message_tx: Sender<Vec<u8>>) -> Self

Creates a new router instance with default configuration

pub fn new_with_config( message_tx: Sender<Vec<u8>>, scoring_config: PeerScoringConfig, optimization_config: RouteOptimizationConfig, dark_addressing_config: DarkAddressingConfig, max_message_size: usize, ) -> Self

Creates a new production-ready router instance with custom configuration

pub fn set_shadow_resolver( &mut self, resolver: Box<dyn ShadowAddressResolver + Send + Sync>, )

Set the shadow address resolver

pub fn add_peer_connection(&mut self, from: LibP2PPeerId, to: LibP2PPeerId)

Adds a peer connection to the routing table

pub fn remove_peer_connection(&mut self, from: LibP2PPeerId, to: LibP2PPeerId)

Removes a peer connection from the routing table

pub async fn add_discovered_peer( &self, peer_id: LibP2PPeerId, peer: DiscoveredPeer, )

Adds a discovered peer with full metrics

pub async fn remove_discovered_peer(&self, peer_id: LibP2PPeerId)

Removes a discovered peer

pub async fn update_path_metrics(&self, peer_id: LibP2PPeerId, path: RoutePath)

Updates path metrics for a peer

pub async fn find_paths( &self, destination: LibP2PPeerId, criteria: &RouteSelectionCriteria, ) -> Result<Vec<RoutePath>, RoutingError>

Finds multiple disjoint paths to a destination

pub async fn route_message( &self, destination: impl Into<Destination>, message: Vec<u8>, ) -> Result<(), RoutingError>

Routes a message through multiple paths using either PeerId or ShadowAddress