Enum TransportHandle 

pub enum TransportHandle {
    Udp(UdpTransport),
    Ethernet(EthernetTransport),
    Tcp(TcpTransport),
    Tor(TorTransport),
    Ble(DefaultBleTransport),
}

Wrapper enum for concrete transport implementations.

This enables polymorphic transport handling without trait objects, supporting async methods that the sync Transport trait cannot express.

Variants

Udp(UdpTransport)

UDP/IP transport.

Ethernet(EthernetTransport)

Raw Ethernet transport.

Tcp(TcpTransport)

TCP/IP transport.

Tor(TorTransport)

Tor transport (via SOCKS5).

Ble(DefaultBleTransport)

BLE L2CAP transport.

Implementations

impl TransportHandle

pub async fn start(&mut self) -> Result<(), TransportError>

Start the transport asynchronously.

pub async fn stop(&mut self) -> Result<(), TransportError>

Stop the transport asynchronously.

pub async fn send( &self, addr: &TransportAddr, data: &[u8], ) -> Result<usize, TransportError>

Send data to a remote address asynchronously.

pub async fn flush_pending_send(&self)

Flush any pending outbound batch buffered by the transport. Called by the rx_loop at end-of-drain so that trailing packets of a burst don’t sit in the buffer waiting for the threshold. Only the UDP transport batches today (via sendmmsg(2)); other transports treat this as a no-op.

pub fn transport_id(&self) -> TransportId

Get the transport ID.

pub fn name(&self) -> Option<&str>

Get the instance name (if configured as a named instance).

pub fn transport_type(&self) -> &TransportType

Get the transport type metadata.

pub fn state(&self) -> TransportState

Get current transport state.

pub fn mtu(&self) -> u16

Get the transport MTU.

pub fn link_mtu(&self, addr: &TransportAddr) -> u16

Get the MTU for a specific link address.

Falls back to transport-wide MTU if the transport doesn’t support per-link MTU or the address is unknown.

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

Get the local bound address (UDP/TCP only, returns None for other transports).

pub fn interface_name(&self) -> Option<&str>

Get the interface name (Ethernet only, returns None for other transports).

pub fn onion_address(&self) -> Option<&str>

Get the onion service address (Tor only, returns None for other transports).

pub fn tor_monitoring(&self) -> Option<TorMonitoringInfo>

Get cached Tor daemon monitoring info (Tor only).

pub fn tor_mode(&self) -> Option<&str>

Get the Tor transport mode (Tor only).

pub fn discover(&self) -> Result<Vec<DiscoveredPeer>, TransportError>

Drain discovered peers from this transport.

pub fn auto_connect(&self) -> bool

Whether this transport auto-connects to discovered peers.

pub fn accept_connections(&self) -> bool

Whether this transport accepts inbound connections.

pub async fn connect(&self, addr: &TransportAddr) -> Result<(), TransportError>

Initiate a non-blocking connection to a remote address.

For connection-oriented transports (TCP, Tor), spawns a background task to establish the connection. For connectionless transports (UDP, Ethernet), this is a no-op that returns Ok immediately.

Poll connection_state() to check when the connection is ready.

pub fn connection_state(&self, addr: &TransportAddr) -> ConnectionState

Query the state of a connection attempt to a remote address.

For connectionless transports, always returns ConnectionState::Connected (they are always “connected”). For connection-oriented transports, returns the current state of the background connection attempt.

pub async fn close_connection(&self, addr: &TransportAddr)

Close a specific connection on this transport.

No-op for connectionless transports. For TCP/Tor, removes the connection from the pool and drops the stream.

pub fn is_operational(&self) -> bool

Check if transport is operational.

pub fn congestion(&self) -> TransportCongestion

Query transport-local congestion indicators.

Returns a snapshot of congestion signals that the transport can observe locally (e.g., kernel receive buffer drops). Fields are None when the transport doesn’t support that signal.

pub fn transport_stats(&self) -> Value

Get transport-specific stats as a JSON value.

Returns a snapshot of counters for the specific transport type.