Struct murmel::p2p::P2P

pub struct P2P<Message: Version + Send + Sync + Clone + 'static, Envelope: Command + Send + Sync + 'static, Config: P2PConfig<Message, Envelope> + Send + Sync + 'static> {
    pub config: Config,
    // some fields omitted
}

The P2P network layer

Fields

config: Config

Methods

impl<Message: Version + Send + Sync + Clone, Envelope: Command + Send + Sync, Config: P2PConfig<Message, Envelope> + Send + Sync> P2P<Message, Envelope, Config>

pub fn new(
    config: Config,
    dispatcher: PeerMessageSender<Message>,
    back_pressure: usize
) -> (Arc<P2P<Message, Envelope, Config>>, P2PControlSender<Message>)

create a new P2P network controller

pub fn connected_peers(&self) -> Vec<SocketAddr>

pub fn n_connected_peers(&self) -> usize

pub fn add_peer(
    &self,
    network: &'static str,
    source: PeerSource
) -> impl Future<Output = Result<SocketAddr, Error>> + Send

return a future that does not complete until the peer is connected

pub fn poll_events(
    &self,
    network: &'static str,
    needed_services: u64,
    spawn: &mut dyn Spawn
)

run the message dispatcher loop this method does not return unless there is an error obtaining network events run in its own thread, which will process all network events