Struct P2pLinkTransport 

pub struct P2pLinkTransport { /* private fields */ }

A LinkTransport implementation wrapping P2pEndpoint.

This provides a stable abstraction layer for overlay networks to use, decoupling them from specific ant-quic versions.

Implementations

impl P2pLinkTransport

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

Create a new LinkTransport from a P2pConfig.

pub fn from_endpoint(endpoint: Arc<P2pEndpoint>) -> Self

Create from an existing P2pEndpoint.

pub fn endpoint(&self) -> &P2pEndpoint

Get the underlying P2pEndpoint.

Trait Implementations

impl LinkTransport for P2pLinkTransport

type Conn = P2pLinkConn

The connection type returned by this transport.

fn local_peer(&self) -> PeerId

Get our local peer ID.

fn external_address(&self) -> Option<SocketAddr>

Get our observed external address (if known).

fn peer_table(&self) -> Vec<(PeerId, Capabilities)>

Get the current peer table with capabilities.

fn peer_capabilities(&self, peer: &PeerId) -> Option<Capabilities>

Get capabilities for a specific peer.

fn subscribe(&self) -> Receiver<LinkEvent>

Subscribe to transport events.

fn accept(&self, _proto: ProtocolId) -> Incoming<Self::Conn>

Accept incoming connections for a specific protocol.

fn dial( &self, peer: PeerId, _proto: ProtocolId, ) -> BoxFuture<'_, LinkResult<Self::Conn>>

Dial a peer to establish a connection.

fn dial_addr( &self, addr: SocketAddr, _proto: ProtocolId, ) -> BoxFuture<'_, LinkResult<Self::Conn>>

Dial a peer by address (for bootstrap).

fn supported_protocols(&self) -> Vec<ProtocolId>

Get the list of protocols we support.

fn register_protocol(&self, proto: ProtocolId)

Register a protocol as supported.

fn unregister_protocol(&self, proto: ProtocolId)

Unregister a protocol.

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

Check if we’re connected to a peer.

fn active_connections(&self) -> usize

Get the number of active connections.

fn shutdown(&self) -> BoxFuture<'_, ()>

Gracefully shutdown the transport.