Struct PeerDiscoveryManager 

pub struct PeerDiscoveryManager {
    pub peers: HashMap<String, DiscoveredPeer>,
    pub max_dial_attempts: u32,
    pub stats: DiscoveryStats,
}

Manages multiple peer discovery mechanisms and deduplicates discovered peers.

Fields

peers: HashMap<String, DiscoveredPeer>

Map from peer_id to its discovery record.

max_dial_attempts: u32

Maximum number of dial attempts before a peer is considered permanently unreachable.

stats: DiscoveryStats

Running statistics.

Implementations

impl PeerDiscoveryManager

pub fn new(max_dial_attempts: u32) -> Self

Create a new manager with the given dial-attempt limit.

pub fn add_peer(&mut self, peer: DiscoveredPeer) -> bool

Attempt to register a newly discovered peer.

Returns true when the peer was inserted (first time seen). Returns false when the peer was already known; stats.duplicates_skipped is incremented in that case.

pub fn record_dial_result(&mut self, peer_id: &str, success: bool)

Record the outcome of a dial attempt for the given peer.

Increments dial_attempts, updates last_dial_result, and bumps the appropriate aggregate counter. If peer_id is unknown this is a no-op.

pub fn candidates_to_dial(&self) -> Vec<&DiscoveredPeer>

Return all peers that should still be dialed, sorted by ascending dial_attempts.

A peer is a candidate when should_retry(max_dial_attempts) is true.

pub fn connected_peers(&self) -> Vec<&DiscoveredPeer>

Return all peers whose last dial was successful.

pub fn failed_peers(&self) -> Vec<&DiscoveredPeer>

Return all peers that have exhausted their dial budget without success.

pub fn peers_by_source(&self, source: DiscoverySource) -> Vec<&DiscoveredPeer>

Return all peers discovered via a specific source.

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

Remove a peer from the manager.

Returns true if the peer was present and has been removed, false otherwise.

pub fn stats(&self) -> &DiscoveryStats

Borrow the current discovery statistics.

pub fn merge_addresses(&mut self, peer_id: &str, new_addrs: &[String])

Merge additional addresses into a known peer’s address list.

Any address already recorded for that peer is silently skipped. If peer_id is unknown this is a no-op.