Struct SnapTunnel 

pub struct SnapTunnel { /* private fields */ }

A SNAP tunnel connection.

Implementations

impl SnapTunnel

pub async fn send(&self, packet: Packet) -> Result<()>

Send a packet to the remote server.

pub fn try_send(&self, packet: Packet) -> Result<()>

Try to send a packet to the remote server. Returns error of try_send_to.

pub async fn recv(&self) -> Result<Bytes, SnapTunnelReceiveError>

Receive a packet from the remote server.

pub fn try_recv(&self) -> Result<Option<Bytes>, SnapTunnelReceiveError>

Try to receive a packet from the remote server without blocking.

Returns Ok(None) if no packet is currently available.

pub fn poll_recv( &self, cx: &mut Context<'_>, ) -> Poll<Result<Bytes, SnapTunnelReceiveError>>

Poll for a packet from the remote server.

pub fn local_addr(&self) -> SocketAddr

Get the local socket address. Assigned by the remote server.

pub async fn writable(&self) -> Result<()>

Check if the socket is writable.

pub fn data_plane_address(&self) -> SocketAddr

The data plane the tunnel is connected to.

pub fn discarded_datagrams(&self) -> u64

Total number of outbound datagrams the underlay socket refused since the tunnel was created.

A refused datagram is dropped rather than retried, because retrying one the socket will never accept blocks every packet queued behind it. The tunnel therefore stays up when sending fails persistently, for example because the interface went down or a firewall answers EPERM, and this counter is what tells such a tunnel apart from a healthy one.

Trait Implementations

impl Drop for SnapTunnel

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.