Struct GossipDiscovery 

pub struct GossipDiscovery { /* private fields */ }

Gossip-based discovery using the chitchat protocol.

Implementations

impl GossipDiscovery

pub fn new(config: GossipDiscoveryConfig) -> Self

Create a new gossip discovery instance.

pub fn chitchat_handle(&self) -> Option<&ChitchatHandle>

Borrow the underlying chitchat handle, if the discovery has been started. Enables other cluster components (barrier coordinator, shuffle peer registry) to share the same chitchat instance rather than spawning their own.

impl GossipDiscovery

pub async fn start_with_transport<T>( &mut self, transport: &T, ) -> Result<(), DiscoveryError>

where T: Transport,

Start with a caller-provided chitchat transport. Test harnesses use this to inject a filtering / fault-injecting transport wrapper (see cluster::testing::PartitionableTransport). The regular Discovery::start just delegates here with a default UdpTransport.

Errors

Same as Discovery::start.

Panics

Panics via unwrap on an internal assertion if called twice concurrently from the same GossipDiscovery — the started flag check makes the second call a no-op.

Trait Implementations

impl Debug for GossipDiscovery

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

Formats the value using the given formatter.

impl Discovery for GossipDiscovery

async fn start(&mut self) -> Result<(), DiscoveryError>

Start the discovery service.

async fn peers(&self) -> Result<Vec<NodeInfo>, DiscoveryError>

Get the current set of known peers (excluding self).

async fn announce(&self, info: NodeInfo) -> Result<(), DiscoveryError>

Announce this node’s updated information to the cluster.

fn membership_watch(&self) -> Receiver<Vec<NodeInfo>>

Subscribe to membership change events.

async fn stop(&mut self) -> Result<(), DiscoveryError>

Gracefully stop the discovery service.