Struct BandwidthMonitor 

pub struct BandwidthMonitor { /* private fields */ }

Monitor that tracks per-peer and aggregate bandwidth usage.

BandwidthMonitor maintains a map of PeerBandwidth entries protected by a RwLock. All mutating operations take a write lock; read-only queries take a read lock. Global byte totals are accumulated in BandwidthStats using lock-free atomics, so callers can take cheap snapshots without acquiring the peer map lock.

The sliding window used for rate calculations is configurable at construction time (defaults to 10 seconds). Samples older than the window are lazily evicted on each call to record.

Implementations

impl BandwidthMonitor

pub fn new() -> Self

Create a new monitor with the default 10-second sliding window.

pub fn with_window(window: Duration) -> Self

Create a new monitor with a custom sliding window duration.

pub fn window(&self) -> Duration

Return the configured sliding window duration.

pub fn stats(&self) -> &Arc<BandwidthStats>

Return a shared reference to the global atomic stats.

pub fn record(&self, peer_id: &str, bytes: u64, direction: Direction)

Record a transfer of bytes in direction for peer_id.

This method:

1. Obtains a write lock on the peer map.
2. Creates a PeerBandwidth entry if one does not exist.
3. Appends a new sample stamped with the current instant.
4. Evicts samples older than the sliding window from that peer.
5. Increments the global atomic counters.

pub fn rate_for_peer(&self, peer_id: &str, direction: Direction) -> f64

Return the current rate (bytes/sec) for peer_id in direction.

Returns 0.0 if the peer is unknown.

pub fn top_senders(&self, n: usize) -> Vec<(String, f64)>

Return the top n peers by outbound rate, sorted descending.

Each element is (peer_id, rate_bps). If there are fewer than n peers, all known peers are returned.

pub fn top_receivers(&self, n: usize) -> Vec<(String, f64)>

Return the top n peers by inbound rate, sorted descending.

Each element is (peer_id, rate_bps).

pub fn total_rate_bps(&self, direction: Direction) -> f64

Compute the aggregate rate (bytes/sec) across all peers for direction.

pub fn evict_idle_peers(&self, max_idle: Duration)

Remove peers whose most recent sample is older than max_idle.

A peer is considered idle when:

• It has no samples at all, or
• Its most recent sample (in either direction) was recorded more than max_idle ago.

pub fn peer_count(&self) -> usize

Return the current number of tracked peers.

pub fn stats_snapshot(&self) -> BandwidthStatsSnapshot

Take a snapshot of the global atomic stats without acquiring the peer map lock.

Trait Implementations

impl Default for BandwidthMonitor

fn default() -> Self

Returns the “default value” for a type.