Enum libp2p::swarm::NetworkBehaviourAction
source · [−]pub enum NetworkBehaviourAction<TInEvent, TOutEvent> {
GenerateEvent(TOutEvent),
DialAddress {
address: Multiaddr,
},
DialPeer {
peer_id: PeerId,
condition: DialPeerCondition,
},
NotifyHandler {
peer_id: PeerId,
handler: NotifyHandler,
event: TInEvent,
},
ReportObservedAddr {
address: Multiaddr,
score: AddressScore,
},
}
Expand description
An action that a NetworkBehaviour
can trigger in the Swarm
in whose context it is executing.
Variants
GenerateEvent(TOutEvent)
Instructs the Swarm
to return an event when it is being polled.
DialAddress
Fields
address: Multiaddr
The address to dial.
Instructs the swarm to dial the given multiaddress, with no knowledge of the PeerId
that
may be reached.
DialPeer
Fields
peer_id: PeerId
The peer to try reach.
condition: DialPeerCondition
The condition for initiating a new dialing attempt.
Instructs the swarm to dial a known PeerId
.
The addresses_of_peer
method is called to determine which addresses to attempt to reach.
If we were already trying to dial this node, the addresses that are not yet in the queue of addresses to try are added back to this queue.
On success, NetworkBehaviour::inject_connected
is invoked.
On failure, NetworkBehaviour::inject_dial_failure
is invoked.
NotifyHandler
Fields
peer_id: PeerId
The peer for whom a ProtocolsHandler
should be notified.
handler: NotifyHandler
The options w.r.t. which connection handler to notify of the event.
Instructs the Swarm
to send an event to the handler dedicated to a
connection with a peer.
If the Swarm
is connected to the peer, the message is delivered to the
ProtocolsHandler
instance identified by the peer ID and connection ID.
If the specified connection no longer exists, the event is silently dropped.
Typically the connection ID given is the same as the one passed to
NetworkBehaviour::inject_event
, i.e. whenever the behaviour wishes to
respond to a request on the same connection (and possibly the same
substream, as per the implementation of ProtocolsHandler
).
Note that even if the peer is currently connected, connections can get closed at any time and thus the event may not reach a handler.
ReportObservedAddr
Fields
address: Multiaddr
The observed address of the local node.
score: AddressScore
The score to associate with this observation, i.e. an indicator for the trusworthiness of this address relative to other observed addresses.
Informs the Swarm
about an address observed by a remote for
the local node by which the local node is supposedly publicly
reachable.
It is advisable to issue ReportObservedAddr
actions at a fixed frequency
per node. This way address information will be more accurate over time
and individual outliers carry less weight.
Implementations
sourceimpl<TInEvent, TOutEvent> NetworkBehaviourAction<TInEvent, TOutEvent>
impl<TInEvent, TOutEvent> NetworkBehaviourAction<TInEvent, TOutEvent>
sourcepub fn map_in<E>(
self,
f: impl FnOnce(TInEvent) -> E
) -> NetworkBehaviourAction<E, TOutEvent>
pub fn map_in<E>(
self,
f: impl FnOnce(TInEvent) -> E
) -> NetworkBehaviourAction<E, TOutEvent>
Map the handler event.
sourcepub fn map_out<E>(
self,
f: impl FnOnce(TOutEvent) -> E
) -> NetworkBehaviourAction<TInEvent, E>
pub fn map_out<E>(
self,
f: impl FnOnce(TOutEvent) -> E
) -> NetworkBehaviourAction<TInEvent, E>
Map the event the swarm will return.
Trait Implementations
Auto Trait Implementations
impl<TInEvent, TOutEvent> RefUnwindSafe for NetworkBehaviourAction<TInEvent, TOutEvent> where
TInEvent: RefUnwindSafe,
TOutEvent: RefUnwindSafe,
impl<TInEvent, TOutEvent> Send for NetworkBehaviourAction<TInEvent, TOutEvent> where
TInEvent: Send,
TOutEvent: Send,
impl<TInEvent, TOutEvent> Sync for NetworkBehaviourAction<TInEvent, TOutEvent> where
TInEvent: Sync,
TOutEvent: Sync,
impl<TInEvent, TOutEvent> Unpin for NetworkBehaviourAction<TInEvent, TOutEvent> where
TInEvent: Unpin,
TOutEvent: Unpin,
impl<TInEvent, TOutEvent> UnwindSafe for NetworkBehaviourAction<TInEvent, TOutEvent> where
TInEvent: UnwindSafe,
TOutEvent: UnwindSafe,
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcepub fn borrow_mut(&mut self) -> &mut T
pub fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more