Struct TokioSocketBase

pub struct TokioSocketBase;

Trait Implementations

impl Clone for TokioSocketBase

fn clone(&self) -> TokioSocketBase

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TokioSocketBase

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

Formats the value using the given formatter.

impl SocketTap<TokioSocketBase> for NetworkTap<TcpStream, TokioSocketBase>

fn connect<'life0, 'async_trait>( &'life0 mut self, conn_timeout: Option<Duration>, ) -> Pin<Box<dyn Future<Output = CDnsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Connects to the remote host.

fn is_encrypted(&self) -> bool

Tells if current instace is encrypted i.e [TcpTlsConnection] over [TcpStream].

fn is_tcp(&self) -> bool

Tells if current instance is [TcpStream] if true, or [UdpSocket] if false

fn should_append_len(&self) -> bool

fn poll_read<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = CDnsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn send<'life0, 'life1, 'async_trait>( &'life0 mut self, sndbuf: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = CDnsResult<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Sends data over wire.

fn recv<'life0, 'life1, 'async_trait>( &'life0 mut self, rcvbuf: &'life1 mut [u8], ) -> Pin<Box<dyn Future<Output = CDnsResult<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Receives data transmitted from remote host. In nonblocking mode it should be called only after the event was polled In blocking mode it will block until received or timeout.

impl SocketTap<TokioSocketBase> for NetworkTap<TcpTlsConnection, TokioSocketBase>

fn connect<'life0, 'async_trait>( &'life0 mut self, conn_timeout: Option<Duration>, ) -> Pin<Box<dyn Future<Output = CDnsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Connects to the remote host.

fn is_encrypted(&self) -> bool

Tells if current instace is encrypted i.e [TcpTlsConnection] over [TcpStream].

fn is_tcp(&self) -> bool

Tells if current instance is [TcpStream] if true, or [UdpSocket] if false

fn should_append_len(&self) -> bool

fn poll_read<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = CDnsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn send<'life0, 'life1, 'async_trait>( &'life0 mut self, sndbuf: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = CDnsResult<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Sends data over wire.

fn recv<'life0, 'life1, 'async_trait>( &'life0 mut self, rcvbuf: &'life1 mut [u8], ) -> Pin<Box<dyn Future<Output = CDnsResult<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Receives data transmitted from remote host. In nonblocking mode it should be called only after the event was polled In blocking mode it will block until received or timeout.

impl SocketTap<TokioSocketBase> for NetworkTap<UdpSocket, TokioSocketBase>

fn connect<'life0, 'async_trait>( &'life0 mut self, _conn_timeout: Option<Duration>, ) -> Pin<Box<dyn Future<Output = CDnsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Connects to the remote host.

fn is_encrypted(&self) -> bool

Tells if current instace is encrypted i.e [TcpTlsConnection] over [TcpStream].

fn is_tcp(&self) -> bool

Tells if current instance is [TcpStream] if true, or [UdpSocket] if false

fn should_append_len(&self) -> bool

fn poll_read<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = CDnsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn send<'life0, 'life1, 'async_trait>( &'life0 mut self, sndbuf: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = CDnsResult<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Sends data over wire.

fn recv<'life0, 'life1, 'async_trait>( &'life0 mut self, rcvbuf: &'life1 mut [u8], ) -> Pin<Box<dyn Future<Output = CDnsResult<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Receives data transmitted from remote host. In nonblocking mode it should be called only after the event was polled In blocking mode it will block until received or timeout.

impl SocketTaps<TokioSocketBase> for TokioSocketBase

type TcpSock = TcpStream

type UdpSock = UdpSocket

type TlsSock = TcpTlsConnection

fn new_tcp_socket( resolver: Arc<ResolveConfEntry>, timeout: Duration, ) -> CDnsResult<Box<NetworkTapType<TokioSocketBase>>>

fn new_udp_socket( resolver: Arc<ResolveConfEntry>, timeout: Duration, ) -> CDnsResult<Box<NetworkTapType<TokioSocketBase>>>

fn new_tls_socket( resolver: Arc<ResolveConfEntry>, timeout: Duration, ) -> CDnsResult<Box<NetworkTapType<TokioSocketBase>>>