Struct Router 

pub struct Router<O: CompressionOracle> { /* private fields */ }

In-memory CMR router.

Implementations

impl<O: CompressionOracle> Router<O>

pub fn new(local_address: String, policy: RoutingPolicy, oracle: O) -> Self

Creates a router instance.

pub fn set_shared_key(&mut self, peer: impl Into<String>, key: Vec<u8>)

Registers a pairwise shared key.

pub fn local_address(&self) -> &str

Local peer address.

pub fn shared_key(&self, peer: &str) -> Option<&[u8]>

Gets known shared key.

pub fn policy(&self) -> &RoutingPolicy

Returns active routing policy.

pub fn set_policy(&mut self, policy: RoutingPolicy)

Replaces active policy and immediately updates cache limits.

pub fn peer_snapshots(&self) -> Vec<PeerSnapshot>

Snapshot of peer metrics.

pub fn peer_count(&self) -> usize

Number of tracked peers.

pub fn known_keys_count(&self) -> usize

Number of configured shared keys.

pub fn pending_key_exchange_count(&self) -> usize

Number of pending key exchange initiator states.

pub fn adjust_reputation(&mut self, peer: &str, delta: f64)

Adjusts peer reputation by delta.

pub fn remove_peer(&mut self, peer: &str) -> bool

Removes a peer from local metrics and key state.

pub fn record_successful_outbound(&mut self, peer: &str, bytes: usize)

Records a successfully delivered outbound message for peer-level accounting.

pub fn cache_local_client_message( &mut self, raw_message: &[u8], now: CmrTimestamp, ) -> Result<(), ProcessError>

Inserts a local client-created message into cache without network-ingress checks.

pub fn cache_stats(&self) -> CacheStats

Current cache summary.

pub fn cache_entries(&self) -> Vec<CacheEntryView>

Cache entries for observability.

pub fn cache_message_distance( &self, left_key: &str, right_key: &str, ) -> Result<Option<f64>, CompressionError>

Computes Section 3.2 distance between two cached messages by cache keys.

pub fn register_pending_rsa_state( &mut self, peer: impl Into<String>, n: BigUint, d: BigUint, )

Stores pending RSA initiator state for incoming replies.

pub fn register_pending_dh_state( &mut self, peer: impl Into<String>, p: BigUint, a_secret: BigUint, )

Stores pending DH initiator state for incoming replies.

pub fn initiate_rsa_key_exchange( &mut self, destination: &str, now: &CmrTimestamp, ) -> Option<ClientMessagePlan>

Builds an RSA key-exchange initiation for a destination peer.

pub fn initiate_dh_key_exchange( &mut self, destination: &str, now: &CmrTimestamp, ) -> Option<ClientMessagePlan>

Builds a DH key-exchange initiation for a destination peer.

pub fn initiate_clear_key_exchange( &mut self, destination: &str, clear_key: Vec<u8>, _now: &CmrTimestamp, ) -> Option<ClientMessagePlan>

Initiates clear key-exchange by sending shared key bytes over a secure channel.

pub fn process_incoming( &mut self, raw_message: &[u8], transport: TransportKind, now: CmrTimestamp, ) -> ProcessOutcome

Processes one inbound message.

pub fn process_local_client_message( &mut self, raw_message: &[u8], transport: TransportKind, now: CmrTimestamp, ) -> ProcessOutcome

Processes one local client-originated message.

This path intentionally skips the recipient-address header guard used for network ingress so local compose/injection can originate from the node’s own canonical address.