Struct AsyncTcpSocket

pub struct AsyncTcpSocket { /* private fields */ }

Asynchronous TCP socket built on top of Tokio.

Implementations

impl AsyncTcpSocket

pub fn from_config(config: &TcpConfig) -> Result<Self>

Create a socket from the given configuration without connecting.

pub fn new(domain: Domain, sock_type: SockType) -> Result<Self>

Create a socket of arbitrary type (STREAM or RAW).

pub fn v4_stream() -> Result<Self>

Convenience constructor for an IPv4 STREAM socket.

pub fn v6_stream() -> Result<Self>

Convenience constructor for an IPv6 STREAM socket.

pub fn raw_v4() -> Result<Self>

IPv4 RAW TCP. Requires administrator privileges.

pub fn raw_v6() -> Result<Self>

IPv6 RAW TCP. Requires administrator privileges.

pub async fn connect(self, target: SocketAddr) -> Result<TcpStream>

Connect to the target asynchronously.

pub async fn connect_timeout( self, target: SocketAddr, timeout: Duration, ) -> Result<TcpStream>

Connect with a timeout to the target address.

pub fn listen(self, backlog: i32) -> Result<TcpListener>

Start listening for incoming connections.

pub fn send_to(&self, buf: &[u8], target: SocketAddr) -> Result<usize>

Send a raw TCP packet. Requires SockType::RAW.

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

Receive a raw TCP packet. Requires SockType::RAW.

pub fn set_reuseaddr(&self, on: bool) -> Result<()>

pub fn set_nodelay(&self, on: bool) -> Result<()>

pub fn set_linger(&self, dur: Option<Duration>) -> Result<()>

pub fn set_ttl(&self, ttl: u32) -> Result<()>

pub fn set_bind_device(&self, iface: &str) -> Result<()>

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

Retrieve the local address of the socket.

pub fn into_tokio_stream(self) -> Result<TcpStream>

Convert the internal socket into a Tokio TcpStream.

pub fn as_raw_fd(&self) -> RawFd

Trait Implementations

impl Debug for AsyncTcpSocket

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.