Struct PeerSelector 

pub struct PeerSelector { /* private fields */ }

Adaptive peer selector

Tracks peer performance and selects peers intelligently:

• Prefers high success rate peers
• Prefers low latency peers
• Backs off failing peers exponentially
• Ensures fairness (no peer gets >30% of traffic with 5+ peers)

Implementations

impl PeerSelector

pub fn new() -> Self

Create a new peer selector with default weighted strategy

pub fn with_strategy(strategy: SelectionStrategy) -> Self

Create with specific strategy

pub fn set_fairness(&mut self, enabled: bool)

Enable/disable fairness constraints

pub fn set_cashu_payment_weight(&mut self, weight: f64)

Configure payment-priority influence when ranking peers. 0.0 disables payment influence and preserves reputation-only behavior.

pub fn add_peer(&mut self, peer_id: impl Into<String>)

Add a peer to track

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

Remove a peer

pub fn get_stats(&self, peer_id: &str) -> Option<&PeerStats>

Get peer stats (immutable)

pub fn get_stats_mut(&mut self, peer_id: &str) -> Option<&mut PeerStats>

Get peer stats (mutable)

pub fn all_stats(&self) -> impl Iterator<Item = &PeerStats>

Get all peer stats

pub fn record_request(&mut self, peer_id: &str, bytes: u64)

Record a request being sent to a peer

pub fn record_success(&mut self, peer_id: &str, rtt_ms: u64, bytes: u64)

Record a successful response

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

Record a timeout

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

Record a failure

pub fn record_cashu_payment(&mut self, peer_id: &str, amount_sat: u64)

Record payment channel credit for a peer.

pub fn record_cashu_receipt(&mut self, peer_id: &str, amount_sat: u64)

Record a settled post-delivery payment received from a peer.

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

Record that a peer failed to settle after we delivered successfully.

pub fn is_peer_blocked_for_payment_defaults( &self, peer_id: &str, threshold: u64, ) -> bool

pub fn select_peers(&mut self) -> Vec<String>

Select peers ordered by preference

Returns all available peers sorted by preference (best first). Respects backoff states and fairness constraints.

pub fn select_best(&mut self) -> Option<String>

Select single best peer

pub fn select_top(&mut self, n: usize) -> Vec<String>

Select top N peers

pub fn summary(&self) -> SelectorSummary

Get summary statistics across all peers

pub fn export_peer_metadata_snapshot(&self) -> PeerMetadataSnapshot

Export persisted peer metadata keyed by stable principal identity.

pub fn import_peer_metadata_snapshot(&mut self, snapshot: &PeerMetadataSnapshot)

Import persisted metadata and apply it to currently tracked peers.

Trait Implementations

impl Debug for PeerSelector

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

Formats the value using the given formatter.

impl Default for PeerSelector

fn default() -> PeerSelector

Returns the “default value” for a type.