Struct PeerBandwidth 

pub struct PeerBandwidth {
    pub peer_id: String,
    pub inbound_samples: VecDeque<BandwidthSample>,
    pub outbound_samples: VecDeque<BandwidthSample>,
    pub total_inbound_bytes: u64,
    pub total_outbound_bytes: u64,
}

Per-peer bandwidth state keeping a sliding window of recent samples.

Fields

peer_id: String

Stable identifier for this peer (e.g. libp2p PeerId string).

inbound_samples: VecDeque<BandwidthSample>

Inbound samples within the current retention window.

outbound_samples: VecDeque<BandwidthSample>

Outbound samples within the current retention window.

total_inbound_bytes: u64

Running total of all inbound bytes ever recorded (never decremented).

total_outbound_bytes: u64

Running total of all outbound bytes ever recorded (never decremented).

Implementations

impl PeerBandwidth

pub fn new(peer_id: impl Into<String>) -> Self

Create a new, empty PeerBandwidth for the given peer.

pub fn record(&mut self, bytes: u64, direction: Direction, now: Instant)

Record a transfer of bytes in direction at time now.

Updates both the sliding-window sample queue and the all-time totals.

pub fn evict_old(&mut self, now: Instant, window: Duration)

Remove samples older than window before now from both queues.

pub fn rate_bps( &self, direction: Direction, now: Instant, window: Duration, ) -> f64

Compute the average rate (bytes/sec) for direction within the last window seconds ending at now.

Returns 0.0 when there are no samples in the window or the window duration is zero.

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

Compute the peak instantaneous rate (bytes/sec) for direction.

The peak is defined as the maximum single-sample byte count divided by the elapsed time since the previous sample in the queue. The very first sample is excluded because there is no prior reference point.

Returns 0.0 when fewer than two samples exist.

pub fn last_activity(&self) -> Option<Instant>

Return the timestamp of the most recent sample in either direction, or None if no samples have been recorded yet.

Trait Implementations

impl Debug for PeerBandwidth

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

Formats the value using the given formatter.