Struct NatTraversalEndpoint 

pub struct NatTraversalEndpoint { /* private fields */ }

High-level NAT traversal endpoint for Autonomi P2P networks

Implementations

impl NatTraversalEndpoint

pub async fn new( config: NatTraversalConfig, event_callback: Option<Box<dyn Fn(NatTraversalEvent) + Send + Sync>>, ) -> Result<Self, NatTraversalError>

Create a new NAT traversal endpoint with optional event callback

pub fn get_quinn_endpoint(&self) -> Option<&Endpoint>

Get the underlying Quinn endpoint

pub fn get_event_callback( &self, ) -> Option<&Box<dyn Fn(NatTraversalEvent) + Send + Sync>>

Get the event callback

pub fn initiate_nat_traversal( &self, peer_id: PeerId, coordinator: SocketAddr, ) -> Result<(), NatTraversalError>

Initiate NAT traversal to a peer (returns immediately, progress via events)

pub fn poll_sessions( &self, ) -> Result<Vec<SessionStateUpdate>, NatTraversalError>

Poll all active sessions and update their states

pub fn start_session_polling(&self, interval: Duration) -> JoinHandle<()>

Start periodic session polling task

pub fn get_statistics( &self, ) -> Result<NatTraversalStatistics, NatTraversalError>

Get current NAT traversal statistics

pub fn add_bootstrap_node( &self, address: SocketAddr, ) -> Result<(), NatTraversalError>

Add a new bootstrap node

pub fn remove_bootstrap_node( &self, address: SocketAddr, ) -> Result<(), NatTraversalError>

Remove a bootstrap node

pub async fn start_listening( &self, bind_addr: SocketAddr, ) -> Result<(), NatTraversalError>

Start listening for incoming connections (async version)

pub async fn connect_to_peer( &self, peer_id: PeerId, server_name: &str, remote_addr: SocketAddr, ) -> Result<QuinnConnection, NatTraversalError>

Connect to a peer using NAT traversal

pub async fn accept_connection( &self, ) -> Result<(PeerId, QuinnConnection), NatTraversalError>

Accept incoming connections on the endpoint

pub fn local_peer_id(&self) -> PeerId

Get the local peer ID

pub fn get_connection( &self, peer_id: &PeerId, ) -> Result<Option<QuinnConnection>, NatTraversalError>

Get an active connection by peer ID

pub fn remove_connection( &self, peer_id: &PeerId, ) -> Result<Option<QuinnConnection>, NatTraversalError>

Remove a connection by peer ID

pub fn list_connections( &self, ) -> Result<Vec<(PeerId, SocketAddr)>, NatTraversalError>

List all active connections

pub async fn handle_connection_data( &self, peer_id: PeerId, connection: &QuinnConnection, ) -> Result<(), NatTraversalError>

Handle incoming data from a connection

pub async fn shutdown(&self) -> Result<(), NatTraversalError>

Shutdown the endpoint

pub async fn discover_candidates( &self, peer_id: PeerId, ) -> Result<Vec<CandidateAddress>, NatTraversalError>

Discover address candidates for a peer

pub fn poll( &self, now: Instant, ) -> Result<Vec<NatTraversalEvent>, NatTraversalError>

Poll for NAT traversal progress and state machine updates

pub fn get_nat_stats( &self, ) -> Result<NatTraversalStatistics, Box<dyn Error + Send + Sync>>

Get NAT traversal statistics

Trait Implementations

impl Debug for NatTraversalEndpoint

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

Formats the value using the given formatter.