Struct PeerMessageRouter 

pub struct PeerMessageRouter {
    pub rules: Vec<RouteRule>,
    pub subscriptions: HashMap<String, Vec<String>>,
    pub next_msg_id: u64,
    pub stats: MessageRouterStats,
}

Routes messages to appropriate peer handlers based on message type and topic subscriptions, supporting both direct and broadcast routing.

Routing semantics

• Direct (to_peer = Some): a single PeerRoutedMessage is produced addressed to the specified peer.
• Broadcast (to_peer = None):
  • MessageType::Gossip: delivered to all peers subscribed to the gossip topic, excluding from_peer.
  • All other types: delivered to all peers that appear as keys in the subscription map and match at least one rule with target_peer = None.
  • If no recipients are found the message is counted as dropped.

Fields

rules: Vec<RouteRule>

Routing rules kept sorted by priority descending.

subscriptions: HashMap<String, Vec<String>>

Topic → list of subscribed peer IDs.

next_msg_id: u64

Next message ID to assign (post-increment semantics).

stats: MessageRouterStats

Aggregate statistics.

Implementations

impl PeerMessageRouter

pub fn new() -> Self

Create a new, empty PeerMessageRouter.

pub fn add_rule(&mut self, rule: RouteRule)

Insert rule, maintaining the invariant that self.rules is sorted by priority descending.

pub fn remove_rule(&mut self, rule_id: u64) -> bool

Remove the rule with the given rule_id.

Returns true if a rule was found and removed, false otherwise.

pub fn subscribe(&mut self, peer_id: &str, topic: &str)

Subscribe peer_id to topic.

If the peer is already subscribed this is a no-op.

pub fn unsubscribe(&mut self, peer_id: &str, topic: &str) -> bool

Unsubscribe peer_id from topic.

Returns true if the peer was subscribed, false if it was not.

pub fn route( &mut self, msg_type: MessageType, from_peer: &str, to_peer: Option<&str>, payload_bytes: u64, tick: u64, ) -> Vec<PeerRoutedMessage>

Route a message, returning one PeerRoutedMessage per recipient.

msg_id is assigned from next_msg_id (pre-increment — the assigned value is used, then next_msg_id is incremented).

pub fn subscribers(&self, topic: &str) -> Vec<&str>

Return all peer IDs subscribed to topic, sorted lexicographically.

pub fn stats(&self) -> &MessageRouterStats

Return a reference to the current statistics.

Trait Implementations

impl Default for PeerMessageRouter

fn default() -> Self

Returns the “default value” for a type.