Struct Litep2pNetworkBackend

pub struct Litep2pNetworkBackend { /* private fields */ }

Networking backend for litep2p.

Trait Implementations

impl<B: BlockT + 'static, H: ExHashT> NetworkBackend<B, H> for Litep2pNetworkBackend

fn bitswap_server( client: Arc<dyn BlockBackend<B> + Send + Sync>, ) -> (Pin<Box<dyn Future<Output = ()> + Send>>, Self::BitswapConfig)

Create Bitswap server.

fn notification_config( protocol_name: ProtocolName, fallback_names: Vec<ProtocolName>, max_notification_size: u64, handshake: Option<NotificationHandshake>, set_config: SetConfig, metrics: NotificationMetrics, peerstore_handle: Arc<dyn PeerStoreProvider>, ) -> (Self::NotificationProtocolConfig, Box<dyn NotificationService>)

Create notification protocol configuration for protocol.

fn request_response_config( protocol_name: ProtocolName, fallback_names: Vec<ProtocolName>, max_request_size: u64, max_response_size: u64, request_timeout: Duration, inbound_queue: Option<Sender<IncomingRequest>>, ) -> Self::RequestResponseProtocolConfig

Create request-response protocol configuration.

fn run<'async_trait>( self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait,

Start Litep2pNetworkBackend event loop.

type NotificationProtocolConfig = NotificationProtocolConfig

Type representing notification protocol-related configuration.

type RequestResponseProtocolConfig = RequestResponseConfig

Type representing request-response protocol-related configuration.

type NetworkService<Block, Hash> = Arc<Litep2pNetworkService>

Type implementing NetworkService for the networking backend.

type PeerStore = Peerstore

Type implementing PeerStore.

type BitswapConfig = Config

Bitswap config.

fn new(params: Params<B, H, Self>) -> Result<Self, Error>

where Self: Sized,

Create new NetworkBackend.

fn network_service(&self) -> Arc<dyn NetworkService>

Get handle to NetworkService of the NetworkBackend.

fn peer_store( bootnodes: Vec<PeerId>, metrics_registry: Option<Registry>, ) -> Self::PeerStore

Create PeerStore.

fn register_notification_metrics( registry: Option<&Registry>, ) -> NotificationMetrics

Register metrics that are used by the notification protocols.