Struct PeerChurnManager 

pub struct PeerChurnManager {
    pub lifetimes: HashMap<String, PeerLifetime>,
    pub events: Vec<ChurnEvent>,
    pub config: ChurnManagerConfig,
}

Manages peer join/leave events, computes churn rate over sliding windows, and provides stability scores for DHT and routing decisions.

Fields

lifetimes: HashMap<String, PeerLifetime>

Per-peer lifetime records, keyed by peer ID.

events: Vec<ChurnEvent>

All events recorded in chronological order.

config: ChurnManagerConfig

Configuration governing window size and stability threshold.

Implementations

impl PeerChurnManager

pub fn new(config: ChurnManagerConfig) -> Self

Creates a new PeerChurnManager with the given configuration.

pub fn record_event(&mut self, event: ChurnEvent)

Records a churn event and updates internal state accordingly.

• Joined: Creates (or replaces, if the peer was previously offline) a PeerLifetime record.
• Left: If the peer is currently online, marks the peer as offline by setting left_tick. If the peer is unknown or already offline, this is a no-op beyond storing the event.

pub fn current_window(&self, current_tick: u64) -> ChurnWindow

Builds the current sliding window ending at current_tick.

The window spans [current_tick - window_size_ticks, current_tick] (saturating at 0), and counts join and leave events within that range.

pub fn stability_score(&self, current_tick: u64) -> f64

Computes a stability score in [0.0, 1.0].

1.0 means no churn; 0.0 means maximum churn (rate ≥ 1.0).

pub fn online_peers(&self) -> Vec<&str>

Returns the peer IDs of all currently online peers, sorted alphabetically.

pub fn peer_lifetime(&self, peer_id: &str) -> Option<&PeerLifetime>

Returns a reference to the PeerLifetime for a given peer ID, if any.

pub fn stats(&self, current_tick: u64) -> ChurnStats

Computes aggregated ChurnStats at the given tick.