Struct DisseminationQueue 

pub struct DisseminationQueue { /* private fields */ }

Bounded dissemination buffer keyed by NodeId.

Implementations

impl DisseminationQueue

pub fn new() -> Self

Fresh empty queue.

pub fn enqueue(&self, update: MemberUpdate)

Insert or replace the entry for update.node_id. The send counter resets to 0 so a fresh rumour is always gossiped anew.

pub fn len(&self) -> usize

Total number of rumours currently in the queue.

pub fn is_empty(&self) -> bool

True when the queue is empty.

pub fn clear(&self)

Drop every rumour. Used by tests and on shutdown.

pub fn take_for_message( &self, max: usize, lambda_log_n: u32, ) -> Vec<MemberUpdate>

Return up to max least-disseminated updates for a single outgoing message. Increments each returned entry’s sent_count and drops entries whose new count has reached lambda_log_n.

lambda_log_n is ceil(lambda * log2(cluster_size + 1)) — computed by the caller because it depends on the current membership size and the super::super::config::SwimConfig fanout_lambda knob.

pub fn fanout_threshold(cluster_size: usize, lambda: u32) -> u32

Compute ceil(lambda * log2(cluster_size + 1)). Exposed so the runner can pass the result straight into [take_for_message].

Trait Implementations

impl Debug for DisseminationQueue

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

Formats the value using the given formatter.

impl Default for DisseminationQueue

fn default() -> DisseminationQueue

Returns the “default value” for a type.