Struct GossipEngine 

pub struct GossipEngine { /* private fields */ }

The gossip engine manages cluster membership and failure detection.

Implementations

impl GossipEngine

pub fn new( local_id: NodeId, local_addr: SocketAddr, config: GossipConfig, event_tx: Sender<GossipEvent>, ) -> Self

Creates a new gossip engine.

pub fn local_id(&self) -> NodeId

Returns the local node ID.

pub fn members(&self) -> impl Iterator<Item = &MemberState>

Returns all known members.

pub fn alive_count(&self) -> usize

Returns the number of alive members (excluding self).

pub fn add_seed(&mut self, id: NodeId, addr: SocketAddr)

Adds a seed node to bootstrap cluster discovery.

pub async fn handle_message( &mut self, msg: GossipMessage, from: SocketAddr, ) -> Option<GossipMessage>

Handles an incoming gossip message.

pub fn tick(&mut self) -> Option<(SocketAddr, GossipMessage)>

Runs one protocol period: probe a random node.

pub fn create_join_message(&self) -> GossipMessage

Creates a join message to send to a seed node.