Struct PeerRegistry 

pub struct PeerRegistry { /* private fields */ }

A registry of peers in the distributed fabric

Implementations

impl PeerRegistry

pub fn new() -> Self

Create a new peer registry

pub fn register(&self, advertisement: PeerAdvertisement) -> Result<(), String>

Register a peer with its advertisement

pub fn unregister( &self, peer_id: &PeerId, ) -> Result<Option<PeerAdvertisement>, String>

Unregister a peer

pub fn get(&self, peer_id: &PeerId) -> Result<Option<PeerAdvertisement>, String>

Get a peer’s advertisement

pub fn peers_for_namespace( &self, namespace: &str, ) -> Result<Vec<PeerAdvertisement>, String>

Find all peers that provide a specific namespace

pub fn peers_for_capability( &self, capability: &str, ) -> Result<Vec<PeerAdvertisement>, String>

Find all peers that provide a specific capability

pub fn all_peers(&self) -> Result<Vec<PeerAdvertisement>, String>

Get all registered peers

pub fn peer_count(&self) -> Result<usize, String>

Get the count of registered peers

pub fn update(&self, advertisement: PeerAdvertisement) -> Result<(), String>

Update a peer’s advertisement

Trait Implementations

impl Clone for PeerRegistry

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for PeerRegistry

fn default() -> Self

Returns the “default value” for a type.