Struct PeerExchangeProtocol 

pub struct PeerExchangeProtocol { /* private fields */ }

Peer Exchange Protocol implementation.

Manages a set of known peers and supports periodic exchange of peer lists with connected peers for decentralised peer discovery.

Implementations

impl PeerExchangeProtocol

pub fn new(config: PexConfig) -> Self

Create a new PeerExchangeProtocol with the given configuration.

pub fn add_peer( &mut self, peer_id: &str, addresses: Vec<String>, source: PeerSource, )

Add or update a known peer.

If the peer already exists, its addresses and last-seen tick are updated. The source is upgraded if the new source has higher priority (Direct > Exchange > Bootstrap).

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

Remove a peer from the known peer set.

Returns true if the peer existed and was removed.

pub fn select_for_exchange(&self) -> Vec<&PexPeerRecord>

Select peers for exchange.

Returns up to max_peers_per_exchange peers, preferring Direct > Exchange > Bootstrap, and within each source category preferring the most recently seen peers.

pub fn receive_exchange(&mut self, peers: Vec<(String, Vec<String>)>)

Receive a set of peers from a peer exchange.

All received peers are added with PeerSource::Exchange. If the total number of known peers exceeds max_known_peers, the oldest peers (by last_seen_tick) are evicted.

pub fn should_exchange(&self) -> bool

Returns true if enough ticks have elapsed since the last exchange to warrant a new one.

pub fn tick(&mut self)

Advance the internal clock by one tick.

pub fn get_peer(&self, peer_id: &str) -> Option<&PexPeerRecord>

Look up a peer by ID.

pub fn peer_count(&self) -> usize

Return the number of known peers.

pub fn peers_by_source(&self, source: PeerSource) -> Vec<&PexPeerRecord>

Return all peers discovered via the given source.

pub fn stats(&self) -> PexStats

Return protocol statistics.