Struct HoprNetwork 

pub struct HoprNetwork {
    pub(crate) tracker: Arc<DashSet<PeerId>>,
    pub(crate) store: Arc<NetworkPeerStore>,
    pub(crate) control: Control,
    pub(crate) protocol: StreamProtocol,
    pub(crate) event_rx: InactiveReceiver<NetworkEvent>,
}

Fields

tracker: Arc<DashSet<PeerId>>

store: Arc<NetworkPeerStore>

control: Control

protocol: StreamProtocol

event_rx: InactiveReceiver<NetworkEvent>

Trait Implementations

impl Clone for HoprNetwork

fn clone(&self) -> HoprNetwork

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for HoprNetwork

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

Formats the value using the given formatter.

impl NetworkStreamControl for HoprNetwork

fn accept( self, ) -> Result<impl Stream<Item = (PeerId, impl AsyncRead + AsyncWrite + Send)> + Send, impl Error>

Starts accepting incoming streams.

fn open<'async_trait>( self, peer: PeerId, ) -> Pin<Box<dyn Future<Output = Result<impl AsyncRead + AsyncWrite + Send, impl Error>> + Send + 'async_trait>>

where Self: 'async_trait,

Opens a new outbound stream to the given peer.

impl NetworkView for HoprNetwork

fn listening_as(&self) -> HashSet<Multiaddr>

Multiaddresses used for listening by the local node.

fn discovered_peers(&self) -> HashSet<PeerId>

Peers collected by the network discovery mechanism.

fn connected_peers(&self) -> HashSet<PeerId>

Peers currently connected and tracked by the network.

fn is_connected(&self, peer: &PeerId) -> bool

Peers currently connected and tracked by the network.

fn multiaddress_of(&self, peer: &PeerId) -> Option<HashSet<Multiaddr>>

Translation of the peer into its known multiaddresses.

fn health(&self) -> Health

Represents perceived health of the network.

fn subscribe_network_events( &self, ) -> impl Stream<Item = NetworkEvent> + Send + 'static

Subscribes to network events (peer connected/disconnected).