Struct lumina_node::p2p::P2p

pub struct P2p { /* private fields */ }

Component responsible for the peer to peer networking handling.

Implementations

impl P2p

pub fn start<B, S>(args: P2pArgs<B, S>) -> Result<Self, P2pError>

where B: Blockstore + 'static, S: Store + 'static,

Creates and starts a new p2p handler.

pub fn mocked() -> (Self, MockP2pHandle)

Creates and starts a new mocked p2p handler.

pub async fn stop(&self) -> Result<(), P2pError>

Stop the P2p.

pub fn local_peer_id(&self) -> &PeerId

Local peer ID on the p2p network.

pub fn header_sub_watcher(&self) -> Receiver<Option<ExtendedHeader>>

Watcher for the latest verified network head headers announced on header-sub.

pub fn peer_tracker_info_watcher(&self) -> Receiver<PeerTrackerInfo>

Watcher for the current PeerTrackerInfo.

pub fn peer_tracker_info(&self) -> Ref<'_, PeerTrackerInfo>

A reference to the current PeerTrackerInfo.

pub async fn init_header_sub( &self, head: ExtendedHeader ) -> Result<(), P2pError>

Initializes header-sub protocol with a given subjective_head.

pub async fn wait_connected(&self) -> Result<(), P2pError>

Wait until the node is connected to any peer.

pub async fn wait_connected_trusted(&self) -> Result<(), P2pError>

Wait until the node is connected to any trusted peer.

pub async fn network_info(&self) -> Result<NetworkInfo, P2pError>

Get current NetworkInfo.

pub async fn header_ex_request( &self, request: HeaderRequest ) -> Result<Vec<ExtendedHeader>, P2pError>

Send a request on the header-ex protocol.

pub async fn get_head_header(&self) -> Result<ExtendedHeader, P2pError>

Request the head header on the header-ex protocol.

pub async fn get_header(&self, hash: Hash) -> Result<ExtendedHeader, P2pError>

Request the header by hash on the header-ex protocol.

pub async fn get_header_by_height( &self, height: u64 ) -> Result<ExtendedHeader, P2pError>

Request the header by height on the header-ex protocol.

pub async fn get_verified_headers_range( &self, from: &ExtendedHeader, amount: u64 ) -> Result<Vec<ExtendedHeader>, P2pError>

Request the headers following the one given with the header-ex protocol.

First header from the requested range will be verified against the provided one, then each subsequent is verified against the previous one.

pub async fn get_row( &self, row_index: u16, block_height: u64 ) -> Result<Row, P2pError>

Request a Row on bitswap protocol.

pub async fn get_sample( &self, row_index: u16, column_index: u16, block_height: u64 ) -> Result<Sample, P2pError>

Request a Sample on bitswap protocol.

This method awaits for a verified Sample until timeout of 10 second is reached. On timeout it is safe to assume that sampling of the block failed.

pub async fn get_namespaced_data( &self, namespace: Namespace, row_index: u16, block_height: u64 ) -> Result<NamespacedData, P2pError>

Request a NamespacedData on bitswap protocol.

pub async fn listeners(&self) -> Result<Vec<Multiaddr>, P2pError>

Get the addresses where P2p listens on for incoming connections.

pub async fn connected_peers(&self) -> Result<Vec<PeerId>, P2pError>

Get the list of connected peers.

pub async fn set_peer_trust( &self, peer_id: PeerId, is_trusted: bool ) -> Result<(), P2pError>

Alter the trust status for a given peer.

Trait Implementations

impl Debug for P2p

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.