Struct NamespaceManager 

pub struct NamespaceManager { /* private fields */ }

Manages namespace ownership across federated peers.

Each peer declares the address patterns it owns. When a message arrives, the namespace manager determines which peers should receive it.

Implementations

impl NamespaceManager

pub fn new(local_namespaces: Vec<String>) -> Self

Create a new namespace manager with local patterns

pub fn register_peer(&mut self, router_id: &str, patterns: Vec<String>)

Register a peer’s namespace patterns

pub fn remove_peer(&mut self, router_id: &str)

Remove a peer’s namespace registrations

pub fn peers_for_address( &self, address: &str, exclude_origin: Option<&str>, ) -> Vec<String>

Get all peers that should receive a message for the given address.

Returns peer router IDs whose namespace patterns match the address. Excludes the origin peer to prevent loops.

pub fn is_local(&self, address: &str) -> bool

Check if an address belongs to the local router’s namespace

pub fn is_remote(&self, address: &str) -> bool

Check if an address belongs to any peer’s namespace

pub fn find_conflicts(&self) -> Vec<(String, String, String)>

Check for namespace conflicts between peers.

Returns pairs of (pattern, peer_a, peer_b) for overlapping namespaces.

pub fn peer_patterns(&self, router_id: &str) -> Option<&Vec<String>>

Get a peer’s registered namespaces

pub fn peers(&self) -> Vec<String>

Get all registered peers

pub fn local_patterns(&self) -> &[String]

Get local namespaces

pub fn peer_count(&self) -> usize

Number of registered peers

Trait Implementations

impl Debug for NamespaceManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.