Struct WebSocketTransport 

pub struct WebSocketTransport { /* private fields */ }

Generic WebSocket physical transport.

Implementations

impl WebSocketTransport

pub fn new( transport_id: TransportId, name: Option<String>, config: WebSocketConfig, packet_tx: PacketTx, identity: &Identity, ) -> Self

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

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

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

pub fn stats(&self) -> WebSocketStatsSnapshot

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

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

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

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

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

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

Trait Implementations

impl Transport for WebSocketTransport

fn transport_id(&self) -> TransportId

Get the transport identifier.

fn transport_type(&self) -> &TransportType

Get the transport type metadata.

fn state(&self) -> TransportState

Get the current state.

fn mtu(&self) -> u16

Get the MTU for this transport.

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

Start the transport.

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

Stop the transport.

fn send( &self, _addr: &TransportAddr, _data: &[u8], ) -> Result<(), TransportError>

Send data to a transport address.

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

Discover potential peers (if supported).

fn auto_connect(&self) -> bool

Whether to auto-connect to peers returned by discover(). Default: false. Concrete transports read from their own config.

fn accept_connections(&self) -> bool

Whether to accept inbound handshake initiations on this transport. Default: true (preserves UDP’s current implicit behavior).

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

Get the MTU for a specific link.

fn close_connection(&self, _addr: &TransportAddr)

Close a specific connection (connection-oriented transports only).