Struct P2pEndpoint 

pub struct P2pEndpoint { /* private fields */ }

P2P endpoint - the primary API for ant-quic

This struct provides the main interface for P2P communication with NAT traversal, connection management, and secure messaging.

Implementations

impl P2pEndpoint

pub async fn new(config: P2pConfig) -> Result<Self, EndpointError>

Create a new P2P endpoint with the given configuration

pub fn peer_id(&self) -> PeerId

Get the local peer ID

pub fn local_addr(&self) -> Option<SocketAddr>

Get the local bind address

pub fn external_addr(&self) -> Option<SocketAddr>

Get observed external address (if discovered)

pub fn public_key_bytes(&self) -> [u8; 32]

Get the public key bytes

pub async fn connect( &self, addr: SocketAddr, ) -> Result<PeerConnection, EndpointError>

Connect to a peer by address (direct connection)

pub async fn connect_to_peer( &self, peer_id: PeerId, coordinator: Option<SocketAddr>, ) -> Result<PeerConnection, EndpointError>

Connect to a peer by ID using NAT traversal

pub async fn accept(&self) -> Option<PeerConnection>

Accept incoming connections

pub async fn disconnect(&self, peer_id: &PeerId) -> Result<(), EndpointError>

Disconnect from a peer

pub async fn send( &self, peer_id: &PeerId, data: &[u8], ) -> Result<(), EndpointError>

Send data to a peer

pub async fn recv( &self, timeout: Duration, ) -> Result<(PeerId, Vec<u8>), EndpointError>

Receive data from any peer (with timeout)

This function first checks the pending data buffer for data that was buffered during authentication, then polls streams from connected peers. The timeout is properly distributed across all peers to avoid O(n*timeout) delays.

pub fn subscribe(&self) -> Receiver<P2pEvent>

Subscribe to endpoint events

pub async fn stats(&self) -> EndpointStats

Get endpoint statistics

pub async fn connection_metrics( &self, peer_id: &PeerId, ) -> Option<ConnectionMetrics>

Get metrics for a specific connection

pub fn nat_stats(&self) -> Result<NatTraversalStatistics, EndpointError>

Get NAT traversal statistics

pub async fn connect_known_peers(&self) -> Result<usize, EndpointError>

Connect to configured known peers

pub async fn add_bootstrap(&self, addr: SocketAddr)

Add a bootstrap node dynamically

pub async fn connected_peers(&self) -> Vec<PeerConnection>

Get list of connected peers

pub async fn is_connected(&self, peer_id: &PeerId) -> bool

Check if a peer is connected

pub async fn is_authenticated(&self, peer_id: &PeerId) -> bool

Check if a peer is authenticated

pub async fn shutdown(&self)

Shutdown the endpoint gracefully

pub fn is_running(&self) -> bool

Check if endpoint is running

Trait Implementations

impl Clone for P2pEndpoint

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for P2pEndpoint

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

Formats the value using the given formatter.