Struct network::peer_manager::builder::PeerManagerBuilder

pub struct PeerManagerBuilder { /* fields omitted */ }

Implementations

impl PeerManagerBuilder

pub fn create(
    chain_id: ChainId,
    network_context: NetworkContext,
    time_service: TimeService,
    listen_address: NetworkAddress,
    peer_metadata_storage: Arc<PeerMetadataStorage>,
    trusted_peers: Arc<RwLock<PeerSet>>,
    authentication_mode: AuthenticationMode,
    channel_size: usize,
    max_concurrent_network_reqs: usize,
    max_frame_size: usize,
    enable_proxy_protocol: bool,
    inbound_connection_limit: usize,
    inbound_rate_limit_config: Option<RateLimitConfig>,
    outbound_rate_limit_config: Option<RateLimitConfig>
) -> Self

pub fn listen_address(&self) -> NetworkAddress

pub fn connection_reqs_tx(&self) -> Sender<PeerId, ConnectionRequest>

pub fn build(&mut self, executor: &Handle) -> &mut Self

Create the configured transport and start PeerManager. Return the actual NetworkAddress over which this peer is listening.

pub fn start(&mut self, executor: &Handle)

pub fn add_connection_event_listener(&mut self) -> Receiver

pub fn add_p2p_service(
    &mut self,
    config: &AppConfig
) -> ((PeerManagerRequestSender, ConnectionRequestSender), (Receiver<(PeerId, ProtocolId), PeerManagerNotification>, Receiver))

Register a peer-to-peer service (i.e., both client and service) for given protocols.

pub fn add_client(
    &mut self,
    config: &AppConfig
) -> (PeerManagerRequestSender, ConnectionRequestSender)

Register a client that’s interested in some set of protocols and return the outbound channels into network.

pub fn add_service(
    &mut self,
    config: &AppConfig
) -> (Receiver<(PeerId, ProtocolId), PeerManagerNotification>, Receiver)

Register a service for handling some protocols.