Struct PeerScoringSystem 

pub struct PeerScoringSystem {
    pub weights: ScoringWeights,
    pub history: HashMap<String, VecDeque<PsPeerScore>>,
    pub max_history: usize,
}

Composite peer quality scoring engine.

Maintains a rolling score history per peer and exposes scoring, ranking, trend analysis, and stale-peer eviction.

Fields

weights: ScoringWeights

Dimension weights used when computing composite scores.

history: HashMap<String, VecDeque<PsPeerScore>>

Rolling score history per peer, keyed by peer ID.

max_history: usize

Maximum number of recent scores retained per peer.

Implementations

impl PeerScoringSystem

pub fn new(weights: ScoringWeights) -> Result<Self, ScoringError>

Construct a new system with the given scoring weights.

Returns ScoringError::WeightsMustSumToOne if the weights do not sum to approximately 1.0.

pub fn with_max_history(self, max_history: usize) -> Self

Construct with a custom max_history capacity.

pub fn score_peer(&self, metrics: &PeerMetrics, now: u64) -> PsPeerScore

Compute a PsPeerScore from raw PeerMetrics without storing it.

Component formulas (all output in [0, 1]):

• Latency : exp(-rtt_ms / 500.0) — 0 ms → 1.0, 500 ms → 0.368, 1 000 ms → 0.135
• Bandwidth : (bandwidth_bps / 1_000_000).min(1.0) — caps at 1 Mbps
• Availability : uptime_fraction.clamp(0, 1)
• Reliability : success_rate.clamp(0, 1)
• GossipQuality : gossip_delivery_rate.clamp(0, 1)
• RoutingQuality : routing_success_rate.clamp(0, 1)

pub fn score_and_record( &mut self, metrics: &PeerMetrics, now: u64, ) -> PsPeerScore

Compute a score and push it into the peer’s history ring-buffer.

If the buffer is at max_history capacity, the oldest entry is evicted.

pub fn history_for(&self, peer_id: &str) -> &[PsPeerScore]

Return the history slice for peer_id (oldest first, newest last).

Returns an empty slice if the peer has no recorded history.

pub fn history_vec(&self, peer_id: &str) -> Vec<&PsPeerScore>

Return a Vec of all history entries for peer_id in order (oldest first, newest last).

Unlike history_for, this always returns the full sequence even when the internal deque is split across two slices.

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

Return the mean composite score for peer_id across all recorded history entries, or None if there is no history.

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

Compute the slope of a linear regression over the composite scores in the peer’s history (positive slope = improving quality over time).

Returns None if fewer than 2 data points are available.

The independent variable is the index in the history sequence (0, 1, 2, …), so the slope represents change per observation step.

pub fn top_peers(&self, n: usize, _now: u64) -> Vec<&PsPeerScore>

Return references to the top n peers ordered by their most-recent composite score (descending).

Peers with no history are excluded.

pub fn evict_stale(&mut self, max_age_ms: u64, now: u64) -> usize

Remove peers whose latest recorded score is older than max_age_ms milliseconds relative to now.

Returns the number of peers evicted.

pub fn stats(&self, max_age_ms: u64, now: u64) -> ScoringStats

Compute aggregate statistics for the scoring system.

max_age_ms and now are used solely to determine which peers are considered “stale” for the ScoringStats::stale_peers field; stale peers are not evicted by this call.

Trait Implementations

impl Debug for PeerScoringSystem

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

Formats the value using the given formatter.

impl Default for PeerScoringSystem

fn default() -> Self

Returns the “default value” for a type.