Struct PeerReputationTracker 

pub struct PeerReputationTracker { /* private fields */ }

Thread-safe tracker that maintains per-peer reputation scores and exposes aggregate statistics via AtomicU64 counters.

Thread Safety

All mutating operations acquire the internal RwLock<HashMap> write lock, while read-only queries acquire only the read lock. The aggregate stats are updated via relaxed atomic stores so they never block readers.

Implementations

impl PeerReputationTracker

pub fn new() -> Self

Creates a new, empty tracker.

pub fn record_event(&self, peer_id: &str, event: PeerReputationEvent)

Records an event for the given peer.

If the peer is unknown a new record initialised to score 0 is created automatically. The function also updates total_bans / total_unbans counters when the event crosses the ban threshold.

pub fn get_score(&self, peer_id: &str) -> f64

Returns the current score for peer_id, or 0.0 if the peer is unknown.

pub fn get_tier(&self, peer_id: &str) -> PeerTier

Returns the PeerTier for peer_id.

Unknown peers are treated as having a score of 0 (PeerTier::Neutral).

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

Returns true when the peer is banned (score <= -50).

pub fn banned_peers(&self) -> Vec<String>

Returns the peer IDs of all currently-banned peers.

pub fn trusted_peers(&self) -> Vec<String>

Returns the peer IDs of all currently-trusted peers (score >= 50).

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

Returns the top n peers by score (descending), as (peer_id, score) pairs.

pub fn apply_decay(&self, elapsed: Duration)

Applies time-based score decay to every tracked peer.

pub fn remove_peer(&self, peer_id: &str)

Removes the reputation record for peer_id. Does nothing if the peer is unknown.

pub fn peer_count(&self) -> usize

Returns the total number of peers currently being tracked.

pub fn stats(&self) -> &PeerReputationStats

Returns a reference to the aggregate statistics.

Trait Implementations

impl Default for PeerReputationTracker

fn default() -> Self

Returns the “default value” for a type.