Struct PeerPool 

pub struct PeerPool { /* private fields */ }

Implementations

impl PeerPool

pub async fn new( network: NetworkType, tls: Connector, max_peers: usize, requirement: PeerRequirement, connect_timeout: Duration, ) -> Result<Self, ChiaQueryError>

Spin up the pool by connecting to max_peers random full-node peers concurrently. Under PeerRequirement::Required at least one peer must succeed, otherwise we return ChiaQueryError::PeerDiscoveryFailed; under PeerRequirement::Optional an empty pool is returned and refills later.

pub fn peak_height(&self) -> u32

Latest peak height observed across all connected peers. Returns 0 if no peak has been received yet.

pub async fn select_peer(&self) -> Option<(Peer, SocketAddr)>

Round-robin select a peer from the pool. Returns None when the pool is empty.

pub async fn eject_peer(&self, addr: SocketAddr)

Remove a peer from the pool and asynchronously connect a replacement.

pub async fn has_peers(&self) -> bool

Whether the pool has at least one usable peer.

pub async fn peer_count(&self) -> usize

How many peers the pool HOLDS right now.

This is a live count of the connections currently in the pool, not max_peers’s target: a pool that is still filling reports what it has, and reports the target only once it has reached it. A caller showing this number to a user is stating a fact about the machine, so a configured intention must never stand in for it.

A peer is removed by eject_peer, which runs when a request to it FAILS. So the count is of peers held and believed usable; a connection that has died silently is still counted until something tries to use it. That is the same liveness standard has_peers has always answered by, made countable.

pub async fn try_refill(&self)

If the pool is under capacity, try to connect one new peer. Also spawns a background task to handle its inbound NewPeakWallet messages.

pub fn spawn_receiver_handler(&self, receiver: Receiver<Message>)

Spawn a background task that reads inbound messages from a peer’s receiver channel and updates the shared peak height. This mirrors the pattern used by chia-block-listener.