Enum Transport 

pub enum Transport {
    Tcp(TcpVariant),
    Unix(UnixStream),
}

Transport layer abstraction

Variants

Tcp(TcpVariant)

TCP socket (plain or TLS)

Unix(UnixStream)

Unix domain socket

Implementations

impl Transport

pub async fn connect_tcp(host: &str, port: u16) -> Result<Self>

Connect via plain TCP

pub async fn connect_tcp_tls( host: &str, port: u16, tls_config: &TlsConfig, ) -> Result<Self>

Connect via TLS-encrypted TCP

pub async fn connect_unix(path: &Path) -> Result<Self>

Connect via Unix socket

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

Write bytes to the transport

pub async fn flush(&mut self) -> Result<()>

Flush the transport

pub async fn read_buf(&mut self, buf: &mut BytesMut) -> Result<usize>

Read bytes into buffer

pub async fn upgrade_to_tls( self, tls_config: &TlsConfig, hostname: &str, ) -> Result<Self>

Upgrade a plain TCP transport to TLS after SSLRequest negotiation.

Consumes self and returns a new Transport with a TLS-encrypted stream. Returns an error if the transport is not a plain TCP connection.

pub async fn shutdown(&mut self) -> Result<()>

Shutdown the transport

pub fn channel_binding_data(&self) -> Option<Vec<u8>>

Extract channel binding data from the transport (if TLS is active).

Returns None for plain TCP or Unix socket connections.

Trait Implementations

impl Debug for Transport

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

Formats the value using the given formatter.