Struct TcpTunnel

pub struct TcpTunnel { /* private fields */ }

Implementations

impl TcpTunnel

pub fn route_key(&self) -> RouteKey

pub fn local_addr(&self) -> SocketAddr

pub fn done(&mut self)

pub fn sender(&self) -> Result<WeakTcpTunnelSender>

impl TcpTunnel

pub async fn send(&self, buf: BytesMut) -> Result<()>

Writing buf to the target denoted by route_key via this tunnel

pub async fn recv(&mut self, buf: &mut [u8]) -> Result<usize>

pub async fn batch_recv<B: AsMut<[u8]>>( &mut self, bufs: &mut [B], sizes: &mut [usize], ) -> Result<usize>

pub async fn recv_from(&mut self, buf: &mut [u8]) -> Result<(usize, RouteKey)>

Receive bytes from this tunnel, which the configured Decoder pre-processes usize in the Ok branch indicates how many bytes are received RouteKey in the Ok branch denotes the source where these bytes are received from

pub async fn batch_recv_from<B: AsMut<[u8]>>( &mut self, bufs: &mut [B], sizes: &mut [usize], ) -> Result<(usize, RouteKey)>

Trait Implementations

impl Drop for TcpTunnel

fn drop(&mut self)

Executes the destructor for this type.