Struct MeshHealthMonitor 

pub struct MeshHealthMonitor { /* private fields */ }

Monitors GossipSub mesh health and manages graft/prune decisions.

The monitor tracks a per-topic peer count relative to the D_low / D_high thresholds defined in the GossipSub specification and implements a backoff-aware heal scheduler so that repeated failed graft attempts do not flood the network.

Implementations

impl MeshHealthMonitor

pub fn new(d_low: usize, d_high: usize) -> Self

Create a new monitor with the given D_low and D_high thresholds.

The heal interval defaults to 30 seconds.

pub fn with_heal_interval(self, secs: u64) -> Self

Create a monitor with an explicit heal interval.

pub fn d_low(&self) -> usize

Return the D_low threshold.

pub fn d_high(&self) -> usize

Return the D_high threshold.

pub fn heal_interval_secs(&self) -> u64

Return the heal interval in seconds.

pub fn heal_attempts(&self) -> u64

Return the number of heal attempts recorded so far.

pub fn is_mesh_underpeered(&self, topic_peer_count: usize) -> bool

Return true when the given peer count is below D_low.

pub fn is_mesh_overloaded(&self, topic_peer_count: usize) -> bool

Return true when the given peer count exceeds D_high.

pub fn health_status(&self, mesh_size: usize) -> MeshHealthStatus

Summarise mesh health given the current peer count.

pub fn suggest_grafts( &self, gossip_peers: &[String], mesh_peers: &[String], ) -> Vec<String>

Suggest peers to graft from the gossip peer cache when the mesh is sparse.

Returns peer IDs that are in gossip_peers but not in mesh_peers. The result is bounded to at most D_high - mesh_size candidates so callers never receive more grafts than needed.

pub fn record_heal_attempt(&mut self)

Record that a heal attempt was made right now.

After calling this should_attempt_heal will return false until the configured heal interval has elapsed.

pub fn should_attempt_heal(&self) -> bool

Return true when sufficient time has passed since the last heal attempt (or no attempt has ever been made) so that a new heal should be tried.