Struct PeerNetwork 

pub struct PeerNetwork { /* private fields */ }

Owns one network thread and one bounded archive-reader thread. Drop requests shutdown and joins both. An archive operation already running is not forcibly interrupted. Source handles do not keep the network alive after this owner.

Implementations

impl PeerNetwork

pub fn start( engine: Arc<Engine>, identity: Keypair, listen: Option<Multiaddr>, announce: Vec<Multiaddr>, ) -> Result<Self, Error>

Listen only when an explicit IP/TCP address is supplied. Port zero is allowed for an ephemeral listener; returned address includes this PeerId. Merely constructing source handles never dials. No peer is a seed by default. announce are operator-chosen public IP/TCP addresses identify advertises.

pub fn start_with_dns( engine: Arc<Engine>, identity: Keypair, (listen, announce): (Option<Multiaddr>, Vec<Multiaddr>), dns: DnsMode, ) -> Result<Self, Error>

As start, with the name resolution mode explicit; DnsMode::Refuse stands in for an unreadable system resolver configuration.

pub fn peer_id(&self) -> PeerId

pub fn connected_peers(&self) -> u64

Distinct peers with at least one established connection right now.

pub fn listen_address(&self) -> Option<Multiaddr>

pub fn dns(&self) -> &Dns

Whether named addresses can be dialed by this overlay.

pub fn listen_addresses(&self) -> Vec<Multiaddr>

Every address the listener is bound to now, with /p2p.

pub fn source(&self, address: PeerAddress) -> PeerSource

pub fn sync_peers(&self, manual: Vec<PeerAddress>) -> SyncPeers

manual peers first, then whoever is connected and on our chain.

pub fn commit_source( &self, chain: Chain, manual: Vec<PeerAddress>, ) -> OverlayCommitSource

pub fn shutdown(self) -> Result<(), Error>

impl PeerNetwork

pub fn set_gossip(&self, peers: Vec<GossipPeer>)

Replace the snapshot served to Peers requests. Order is preserved; the first entries are the ones a bounded request receives.

pub fn observed_addrs(&self) -> Vec<Multiaddr>

Public addresses connected peers reported observing for this node.

pub fn connected_peer_ids(&self) -> Vec<PeerId>

Peers with at least one established connection right now, sorted.

pub fn drain_identified(&self) -> Vec<(PeerId, Vec<Multiaddr>)>

Connected peers’ own literal public addresses learned through identify since the last call, newest 64 peers; the queue is emptied.

pub fn dial( &self, address: Multiaddr, cancelled: &AtomicBool, deadline: Instant, ) -> Result<PeerId, Error>

Dial an address (with or without /p2p), then probe the peer with a zero-limit Peers request. Returns the authenticated identity; the connection stays for later requests. A Busy probe is an error that keeps the connection; any other failed probe closes it: the peer is on another chain or does not speak this protocol.

pub fn peers_of( &self, peer: PeerId, limit: u32, cancelled: &AtomicBool, deadline: Instant, ) -> Result<Vec<GossipPeer>, Error>

One bounded Peers request over an existing connection (or addresses the swarm already knows). limit is at most PEERS_MAX; 0 is a bare probe.

Trait Implementations

impl Drop for PeerNetwork

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.