Struct QosRegistry 

pub struct QosRegistry { /* private fields */ }

In-memory map of peer_id → PeerQos for the local node.

Held inside DaemonState under a RwLock:

pub qos: RwLock<QosRegistry>,

Implementations

impl QosRegistry

pub fn new() -> Self

pub fn entry(&mut self, peer_id: impl Into<String>) -> &mut PeerQos

Return (or lazily create) the QoS record for peer_id.

pub fn get(&self, peer_id: &str) -> Option<&PeerQos>

Read-only view of a peer’s QoS; returns None if never seen.

pub fn remove(&mut self, peer_id: &str)

Remove a peer (e.g. on explicit Farewell or eviction).

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

Stability score for peer_id. Returns 0.0 if never seen.

pub fn all_stability_scores(&self) -> Vec<f64>

Snapshot of all stability scores as a Vec<f64> (order not defined).

This is the primary input to crate::coding::params::compute_coding_params.

pub fn stability_scores_for<'a>( &self, pouch_peer_ids: impl Iterator<Item = &'a str>, ) -> Vec<f64>

Stability scores only for Pouch peers whose peer_id appears in pouch_peer_ids — used to scope the k-calculation to active Pouches in a specific network, rather than all connected peers.

pub fn peer_count(&self) -> usize

Total number of tracked peers.

pub fn peer_ids(&self) -> impl Iterator<Item = &str>

All peer IDs currently tracked.

pub fn fault_status(&self, peer_id: &str) -> &'static str

Fault status of a peer: "ok", "degraded", "suspected", or "blacklisted". Returns "ok" if the peer has never been seen.

pub fn fault_score(&self, peer_id: &str) -> u8

Fault score of a peer in [0, 100]. Returns 0 if never seen.

Trait Implementations

impl Debug for QosRegistry

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

Formats the value using the given formatter.

impl Default for QosRegistry

fn default() -> QosRegistry

Returns the “default value” for a type.