Struct GossipOverlayManager 

pub struct GossipOverlayManager {
    pub stats: GossipStats,
    /* private fields */
}

Manages the application-level gossip overlay.

All operations are thread-safe; queues and state are protected by Mutex/RwLock.

Typical usage pattern

1. Register known peers via add_peer.
2. On network receive, call receive; it deduplicates and enqueues.
3. Periodically call drain_outbound to obtain (target, msg) pairs and forward them over the transport layer.
4. Call drain_inbound to pull novel messages for local processing.

Fields

stats: GossipStats

Implementations

impl GossipOverlayManager

pub fn with_fanout(fanout: usize) -> Self

Create a manager with a custom fanout width.

pub fn add_peer(&self, peer_id: String)

Register a peer as a fanout candidate.

pub fn remove_peer(&self, peer_id: &str)

Deregister a peer from the fanout candidate list.

pub fn peer_count(&self) -> usize

Number of registered fanout candidate peers.

pub fn receive(&self, msg: GossipMessage) -> bool

Process an incoming message.

Returns true when the message is novel (first time this sequence number from this peer has been seen). When novel, the message is:

• pushed to the inbound queue for application processing, and
• pushed to the outbound queue for each fanout target.

Returns false and increments the duplicate counter when the message was already seen.

pub fn drain_inbound(&self) -> Vec<GossipMessage>

Drain and return all messages currently in the inbound queue.

pub fn drain_outbound(&self) -> Vec<(String, GossipMessage)>

Drain and return all (target_peer_id, message) pairs from the outbound queue.

pub fn broadcast(&self, msg: GossipMessage)

Broadcast msg to all registered fanout peers (ignoring the message’s own peer_id as a sender — useful for locally-originated messages).

pub fn stats_snapshot(&self) -> GossipStatsSnapshot

A point-in-time snapshot of all gossip counters.

Trait Implementations

impl Debug for GossipOverlayManager

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

Formats the value using the given formatter.

impl Default for GossipOverlayManager

fn default() -> GossipOverlayManager

Returns the “default value” for a type.