Struct PeerBandwidthMonitor 

pub struct PeerBandwidthMonitor {
    pub windows: HashMap<String, PeerBandwidthWindow>,
    pub config: MonitorConfig,
    pub stats: BandwidthMonitorStats,
    pub pending_anomalies: Vec<BandwidthAnomaly>,
}

Tracks per-peer and aggregate bandwidth over a sliding tick window.

Call record on each tick per peer. Spike anomalies are appended to pending_anomalies and can be retrieved with drain_anomalies. Idle anomalies are computed on demand via check_idle.

Fields

windows: HashMap<String, PeerBandwidthWindow>

Per-peer sliding windows, keyed by peer_id.

config: MonitorConfig

Monitor configuration.

stats: BandwidthMonitorStats

Aggregate statistics.

pending_anomalies: Vec<BandwidthAnomaly>

Anomalies detected during record calls; cleared by drain_anomalies.

Implementations

impl PeerBandwidthMonitor

pub fn new(config: MonitorConfig) -> Self

Create a new monitor with the given configuration.

pub fn record( &mut self, peer_id: &str, tick: u64, bytes_sent: u64, bytes_recv: u64, )

Record a bandwidth sample for peer_id at logical tick.

Automatically creates a window entry for new peers. After recording, checks for send/receive spikes and appends any detected BandwidthAnomaly to pending_anomalies.

pub fn drain_anomalies(&mut self) -> Vec<BandwidthAnomaly>

Take all pending anomalies, leaving an empty list.

pub fn check_idle(&mut self, current_tick: u64) -> Vec<BandwidthAnomaly>

Scan all tracked peers for idle conditions at current_tick.

A peer is idle when it has no samples in its window or its most recent sample tick is more than idle_threshold_ticks behind current_tick.

Unlike spike detection, idle anomalies are returned directly and are NOT added to pending_anomalies.

pub fn peer_window(&self, peer_id: &str) -> Option<&PeerBandwidthWindow>

Return a shared reference to the sliding window for peer_id, if any.

pub fn stats(&self) -> &BandwidthMonitorStats

Return a shared reference to the aggregate statistics.