Struct ClusterServiceRegistry 

pub struct ClusterServiceRegistry { /* private fields */ }

Cluster-wide service registry built from advertisements.

Implementations

impl ClusterServiceRegistry

pub fn new() -> Self

pub fn set_chain_manager(&mut self, cm: Arc<ChainManager>)

Attach a chain manager for exochain audit logging.

pub fn merge(&mut self, advert: ServiceAdvertisement)

Merge a service advertisement (add or update).

pub fn resolve(&self, name: &str) -> Vec<&ServiceAdvertisement>

Resolve a service by name. Returns all nodes hosting it.

pub fn resolve_preferred( &self, name: &str, preferred_node: &str, ) -> Option<&ServiceAdvertisement>

Resolve a service, preferring a specific node.

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

List all known service names.

pub fn remove_node(&mut self, node_id: &str)

Remove all services from a node.

pub fn all_advertisements(&self) -> Vec<&ServiceAdvertisement>

Get all advertisements (for gossip).

pub fn service_count(&self) -> usize

Number of unique services.

pub fn total_advertisements(&self) -> usize

Total number of advertisements (across all replicas).

pub fn resolve_round_robin( &self, name: &str, counter: &AtomicU64, ) -> Option<&ServiceAdvertisement>

Resolve a service using round-robin across replicas.

The caller provides a shared atomic counter that is incremented on each call, distributing requests evenly across all nodes hosting the named service.

Trait Implementations

impl Default for ClusterServiceRegistry

fn default() -> Self

Returns the “default value” for a type.