Struct GossipDiscovery 

pub struct GossipDiscovery { /* private fields */ }

Gossip-based discovery protocol

Implementations

impl GossipDiscovery

pub fn new( local_node: ClusterNode, seed_nodes: Vec<SocketAddr>, gossip_interval: Duration, node_timeout: Duration, ) -> Self

Create a new gossip discovery service

pub async fn start(&self) -> Result<()>

Start the gossip protocol

pub fn merge_gossip(&self, remote_nodes: Vec<ClusterNode>)

Merge gossip information from another node

pub fn prune_failed_nodes(&self)

Remove failed nodes

pub fn get_stats(&self) -> GossipStats

Get gossip statistics

Trait Implementations

impl DiscoveryService for GossipDiscovery

fn discover_nodes<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<ClusterNode>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Discover nodes in the cluster

fn register_node<'life0, 'async_trait>( &'life0 self, node: ClusterNode, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Register this node in the discovery service

fn unregister_node<'life0, 'life1, 'async_trait>( &'life0 self, node_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Unregister this node from the discovery service

fn heartbeat<'life0, 'life1, 'async_trait>( &'life0 self, node_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update node heartbeat