Struct PeerLatencyTracker 

pub struct PeerLatencyTracker { /* private fields */ }

Tracks per-peer RTT measurements with histogram, percentile, and ranking support.

Each peer maintains a fixed-size ring buffer of raw latency samples. Statistics (min, max, sum, count) are tracked cumulatively so that mean computation remains accurate even after samples are evicted.

Implementations

impl PeerLatencyTracker

pub fn new(max_samples_per_peer: usize) -> Self

Create a new tracker with the specified ring buffer size per peer.

pub fn record(&mut self, peer_id: &str, latency_us: u64)

Record a latency sample for the given peer.

A PeerLatency entry is automatically created if one does not already exist. The ring buffer evicts the oldest sample when full.

pub fn percentile(&self, peer_id: &str, p: f64) -> Option<u64>

Compute a percentile value for a peer using linear interpolation.

p must be in [0.0, 1.0] (e.g., 0.99 for p99). Returns None if the peer is unknown or has no samples.

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

Compute the mean latency for a peer.

Uses cumulative sum/count for accuracy, not just buffered samples. Returns None if the peer is unknown or has no samples.

pub fn median(&self, peer_id: &str) -> Option<u64>

Compute the median (p50) latency for a peer.

Returns None if the peer is unknown or has no samples.

pub fn histogram( &self, peer_id: &str, bucket_count: usize, ) -> Option<Vec<LatencyBucket>>

Generate a histogram of latency samples for a peer.

The range [min, max] is divided into bucket_count equal-width buckets. Returns None if the peer is unknown, has no samples, or bucket_count is 0.

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

Return the n peers with the lowest mean latency.

Results are sorted ascending by mean latency.

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

Return the n peers with the highest mean latency.

Results are sorted descending by mean latency.

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

Remove all tracking state for peer_id.

Returns true if the peer existed and was removed.

pub fn peer_count(&self) -> usize

Return the number of peers currently being tracked.

pub fn global_mean(&self) -> Option<f64>

Compute the global mean latency across all peers.

Returns None when no samples have been recorded.

pub fn stats(&self) -> LatencyTrackerStats

Return aggregate statistics for the tracker.

Trait Implementations

impl Debug for PeerLatencyTracker

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

Formats the value using the given formatter.