Struct polkadot_node_network_protocol::request_response::network::FullNetworkConfiguration

pub struct FullNetworkConfiguration<B, H, N>
where
    B: Block + 'static,
    H: ExHashT,
    N: NetworkBackend<B, H>,
{
    pub network_config: NetworkConfiguration,
    pub metrics_registry: Option<Registry>,
    /* private fields */
}

Full network configuration.

Fields

network_config: NetworkConfiguration

Network configuration.

metrics_registry: Option<Registry>

Registry for recording prometheus metrics to.

Implementations

impl<B, H, N> FullNetworkConfiguration<B, H, N>

where B: Block + 'static, H: ExHashT, N: NetworkBackend<B, H>,

pub fn new( network_config: &NetworkConfiguration, metrics_registry: Option<Registry>, ) -> FullNetworkConfiguration<B, H, N>

Create new FullNetworkConfiguration.

pub fn add_notification_protocol( &mut self, config: <N as NetworkBackend<B, H>>::NotificationProtocolConfig, )

Add a notification protocol.

pub fn notification_protocols( &self, ) -> &Vec<<N as NetworkBackend<B, H>>::NotificationProtocolConfig>

Get reference to installed notification protocols.

pub fn add_request_response_protocol( &mut self, config: <N as NetworkBackend<B, H>>::RequestResponseProtocolConfig, )

Add a request-response protocol.

pub fn peer_store_handle(&self) -> Arc<dyn PeerStoreProvider>

Get handle to PeerStore.

pub fn take_peer_store(&mut self) -> <N as NetworkBackend<B, H>>::PeerStore

Take PeerStore.

PeerStore is created when FullNetworkConfig is initialized so that PeerStoreHandles can be passed onto notification protocols. PeerStore itself should be started only once and since technically it’s not a libp2p task, it should be started with SpawnHandle in builder.rs instead of using the libp2p/litep2p executor in the networking backend. This function consumes PeerStore and starts its event loop in the appropriate place.

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

Verify addresses are consistent with enabled transports.

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

Check for duplicate bootnodes.

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

Collect all reserved nodes and bootnodes addresses.