Struct PeerAdaptiveTimeout 

pub struct PeerAdaptiveTimeout {
    pub estimates: HashMap<String, TimeoutEstimate>,
    pub config: AdaptiveTimeoutConfig,
    pub total_samples: u64,
}

Per-peer adaptive timeout manager.

Maintains a TimeoutEstimate for every peer that has provided at least one RTT sample and exposes methods to query the recommended timeout or remove stale peers.

Fields

estimates: HashMap<String, TimeoutEstimate>

Map from peer_id to its current timeout estimate.

config: AdaptiveTimeoutConfig

Algorithm configuration.

total_samples: u64

Total RTT samples recorded across all peers (monotonically increasing).

Implementations

impl PeerAdaptiveTimeout

pub fn new(config: AdaptiveTimeoutConfig) -> Self

Create a new PeerAdaptiveTimeout with the given configuration.

pub fn record_sample(&mut self, sample: RttSample)

Record a new RTT sample and update the timeout estimate for the associated peer.

First sample

SRTT   = rtt
RTTVAR = rtt / 2

Subsequent samples

RTTVAR = (1 - β) * RTTVAR + β * |SRTT - rtt|
SRTT   = (1 - α) * SRTT   + α * rtt

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

Returns the recommended timeout for peer_id if it has been tracked, or None otherwise.

pub fn timeout_or_default(&self, peer_id: &str) -> u64

Returns the recommended timeout for peer_id, falling back to max_timeout_micros for unknown peers (conservative default).

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

Remove all state for peer_id.

Returns true if the peer was tracked and has been removed, false if it was unknown.

pub fn stats(&self) -> TimeoutStats

Compute aggregate statistics over all currently tracked peers.

Trait Implementations

impl Debug for PeerAdaptiveTimeout

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

Formats the value using the given formatter.