Struct ConnectionHealthMonitor 

pub struct ConnectionHealthMonitor {
    pub thresholds: AlertThresholds,
    pub connections: HashMap<String, ConnectionHealth>,
    pub alerts: VecDeque<ChmHealthAlert>,
    pub max_alerts: usize,
}

Tracks connection quality metrics per peer with health scoring, anomaly detection, and alerting.

Fields

thresholds: AlertThresholds

Threshold configuration for generating alerts.

connections: HashMap<String, ConnectionHealth>

Per-peer health records.

alerts: VecDeque<ChmHealthAlert>

Ring buffer of recent alerts.

max_alerts: usize

Maximum number of alerts to retain.

Implementations

impl ConnectionHealthMonitor

pub fn new(thresholds: AlertThresholds, max_alerts: usize) -> Self

Create a new monitor with the given thresholds and alert capacity.

pub fn record(&mut self, sample: ChmHealthSample) -> Vec<ChmHealthAlert>

Record a new sample for a peer, recompute its health score, and return any new alerts that were triggered.

pub fn health_score(&self, peer_id: &str) -> Option<f64>

Return the current health score for a peer, if tracked.

pub fn compute_health_score(conn: &ConnectionHealth) -> f64

Compute the composite health score from a peer’s sample window.

Components and weights:

• Latency (0.30): exp(-avg_latency / 1000.0)
• Bandwidth (0.20): (avg_bandwidth / 1_000_000.0).min(1.0)
• Availability (0.20): 1.0 - avg_packet_loss
• Jitter (0.15): exp(-avg_jitter / 200.0)
• Reliability (0.15): 1.0 - avg_error_rate

Missing metrics default to 0.5.

pub fn check_thresholds( &self, peer_id: &str, metric: &ChmHealthMetric, value: f64, now: u64, ) -> Vec<ChmHealthAlert>

Check whether value crosses warning or critical thresholds for the given metric, and return any generated alerts.

pub fn peers_below_threshold(&self, min_score: f64) -> Vec<&str>

Return the IDs of peers whose health score is below min_score, sorted lexicographically.

pub fn recent_alerts(&self, since: u64) -> Vec<&ChmHealthAlert>

Return all alerts with timestamp >= since.

pub fn clear_peer(&mut self, peer_id: &str) -> bool

Remove all health data for a peer. Returns true if the peer existed.

pub fn evict_stale(&mut self, max_age_ms: u64, now: u64) -> usize

Evict peers that have not been updated within max_age_ms milliseconds.

Returns the number of peers evicted.

pub fn top_peers(&self, n: usize) -> Vec<(&str, f64)>

Return the top n peers by health score in descending order.

pub fn stats(&self) -> ChmMonitorStats

Compute aggregate statistics across all tracked peers.