Struct P2P 

pub struct P2P { /* private fields */ }

The main struct coordinating all P2P activity.

Implementations

impl P2P

pub fn new(config: Config) -> Result<Arc<P2P>, Error>

Instantiate a P2P coordinator.

pub fn config(&self) -> &Config

Get the configuration of the P2P instance.

pub fn set_height(&self, block_height: u32)

Set the latest block height to advertise to peers.

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

Shut down the p2p operation. Any subsequent call will be a no-op.

pub fn add_peer<S: IntoMioTcpStream>( &self, conn: S, peer_type: PeerType, ) -> Result<PeerId, Error>

Add a new peer from an opened TCP stream.

pub fn connect_peer(&self, addr: SocketAddr) -> Result<PeerId, Error>

Connect to the given peer.

pub fn disconnect_peer(&self, peer: PeerId) -> Result<(), Error>

Disconnect the given peer.

pub fn ban_peer(&self, peer: PeerId) -> Result<(), Error>

Disconnect the peer and don’t reconnect to it.

pub fn nb_connected_peers(&self) -> usize

The number of connected peers.

pub fn peer_version( &self, peer: PeerId, ) -> Result<Option<VersionMessage>, Error>

Get the peer’s version message.

pub fn send_message( &self, peer: PeerId, msg: NetworkMessage, ) -> Result<(), Error>

Send a message to the given peer.

pub fn broadcast_message(&self, msg: NetworkMessage) -> Result<(), Error>

Broadcast the message to all peers.

pub fn queue_inventory(&self, peer: PeerId, inv: Inventory) -> Result<(), Error>

Add an inventory item to send to the peer. They are trickled with randomized intervals.

Blocks are not queued up, but sent immediatelly. Don’t use this to send inv messages directly, f.e. when replying to mempool. Just use send_message for that.

pub fn broadcast_inventory(&self, inv: Inventory) -> Result<(), Error>

Broadcast an inventory item to all peers. They are tricled with randomized intervals.

Blocks are not queued up, but sent immediatelly.

pub fn add_listener<L: Listener + 'static>( &self, listener: L, ) -> Result<(), Error>

Add a new listener.

See the documentation on the Listener trait to see what common types implement this trait.