Struct libp2p_autonat::Behaviour
source · pub struct Behaviour { /* private fields */ }
Expand description
NetworkBehaviour
for AutoNAT.
The behaviour frequently runs probes to determine whether the local peer is behind NAT and/ or a firewall, or
publicly reachable.
In a probe, a dial-back request is sent to a peer that is randomly selected from the list of fixed servers and
connected peers. Upon receiving a dial-back request, the remote tries to dial the included addresses. When a
first address was successfully dialed, a status Ok will be send back together with the dialed address. If no address
can be reached a dial-error is send back.
Based on the received response, the sender assumes themselves to be public or private.
The status is retried in a frequency of Config::retry_interval
or Config::retry_interval
, depending on whether
enough confidence in the assumed NAT status was reached or not.
The confidence increases each time a probe confirms the assumed status, and decreases if a different status is reported.
If the confidence is 0, the status is flipped and the Behaviour will report the new status in an OutEvent
.
Implementations§
source§impl Behaviour
impl Behaviour
pub fn new(local_peer_id: PeerId, config: Config) -> Self
sourcepub fn public_address(&self) -> Option<&Multiaddr>
pub fn public_address(&self) -> Option<&Multiaddr>
Assumed public address of the local peer.
Returns None
in case of status NatStatus::Private
or NatStatus::Unknown
.
sourcepub fn nat_status(&self) -> NatStatus
pub fn nat_status(&self) -> NatStatus
Assumed NAT status.
sourcepub fn confidence(&self) -> usize
pub fn confidence(&self) -> usize
Confidence in the assumed NAT status.
sourcepub fn add_server(&mut self, peer: PeerId, address: Option<Multiaddr>)
pub fn add_server(&mut self, peer: PeerId, address: Option<Multiaddr>)
Add a peer to the list over servers that may be used for probes. These peers are used for dial-request even if they are currently not connection, in which case a connection will be establish before sending the dial-request.
sourcepub fn remove_server(&mut self, peer: &PeerId)
pub fn remove_server(&mut self, peer: &PeerId)
Remove a peer from the list of servers.
See Behaviour::add_server
for more info.
sourcepub fn probe_address(&mut self, candidate: Multiaddr)
pub fn probe_address(&mut self, candidate: Multiaddr)
Explicitly probe the provided address for external reachability.
Trait Implementations§
source§impl NetworkBehaviour for Behaviour
impl NetworkBehaviour for Behaviour
§type ConnectionHandler = <Behaviour<AutoNatCodec> as NetworkBehaviour>::ConnectionHandler
type ConnectionHandler = <Behaviour<AutoNatCodec> as NetworkBehaviour>::ConnectionHandler
source§fn poll(
&mut self,
cx: &mut Context<'_>,
params: &mut impl PollParameters
) -> Poll<ToSwarm<<Behaviour as NetworkBehaviour>::ToSwarm, THandlerInEvent<Behaviour>>>
fn poll( &mut self, cx: &mut Context<'_>, params: &mut impl PollParameters ) -> Poll<ToSwarm<<Behaviour as NetworkBehaviour>::ToSwarm, THandlerInEvent<Behaviour>>>
source§fn handle_pending_inbound_connection(
&mut self,
connection_id: ConnectionId,
local_addr: &Multiaddr,
remote_addr: &Multiaddr
) -> Result<(), ConnectionDenied>
fn handle_pending_inbound_connection( &mut self, connection_id: ConnectionId, local_addr: &Multiaddr, remote_addr: &Multiaddr ) -> Result<(), ConnectionDenied>
source§fn handle_established_inbound_connection(
&mut self,
connection_id: ConnectionId,
peer: PeerId,
local_addr: &Multiaddr,
remote_addr: &Multiaddr
) -> Result<THandler<Self>, ConnectionDenied>
fn handle_established_inbound_connection( &mut self, connection_id: ConnectionId, peer: PeerId, local_addr: &Multiaddr, remote_addr: &Multiaddr ) -> Result<THandler<Self>, ConnectionDenied>
source§fn handle_pending_outbound_connection(
&mut self,
connection_id: ConnectionId,
maybe_peer: Option<PeerId>,
addresses: &[Multiaddr],
effective_role: Endpoint
) -> Result<Vec<Multiaddr>, ConnectionDenied>
fn handle_pending_outbound_connection( &mut self, connection_id: ConnectionId, maybe_peer: Option<PeerId>, addresses: &[Multiaddr], effective_role: Endpoint ) -> Result<Vec<Multiaddr>, ConnectionDenied>
source§fn handle_established_outbound_connection(
&mut self,
connection_id: ConnectionId,
peer: PeerId,
addr: &Multiaddr,
role_override: Endpoint
) -> Result<THandler<Self>, ConnectionDenied>
fn handle_established_outbound_connection( &mut self, connection_id: ConnectionId, peer: PeerId, addr: &Multiaddr, role_override: Endpoint ) -> Result<THandler<Self>, ConnectionDenied>
source§fn on_swarm_event(&mut self, event: FromSwarm<'_, Self::ConnectionHandler>)
fn on_swarm_event(&mut self, event: FromSwarm<'_, Self::ConnectionHandler>)
Swarm
.source§fn on_connection_handler_event(
&mut self,
peer_id: PeerId,
connection_id: ConnectionId,
event: THandlerOutEvent<Self>
)
fn on_connection_handler_event( &mut self, peer_id: PeerId, connection_id: ConnectionId, event: THandlerOutEvent<Self> )
ConnectionHandler
dedicated to the peer identified by peer_id
. for the behaviour. Read more