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

Errors

Returns Error::Io if the TCP connection fails.

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

Connect via TLS-encrypted TCP using PostgreSQL SSL negotiation protocol.

PostgreSQL requires a specific SSL upgrade sequence:

1. Send SSLRequest message (8 bytes)
2. Server responds with ‘S’ (accept) or ‘N’ (reject)
3. If accepted, perform TLS handshake

Errors

Returns Error::Io if the TCP connection or SSL negotiation fails. Returns Error::Config if the server rejects SSL, sends an unexpected response, the hostname is invalid for TLS, or the TLS handshake fails.

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

Connect via Unix socket

Errors

Returns Error::Io if the Unix socket connection fails.

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

Write bytes to the transport

Errors

Returns Error::Io if the write operation fails.

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

Flush the transport

Errors

Returns Error::Io if the flush operation fails.

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

Read bytes into buffer

Errors

Returns Error::Io if the read operation fails.

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

Shutdown the transport

Errors

Returns Error::Io if the shutdown operation fails.

pub fn apply_keepalive(&self, idle: Duration) -> Result<()>

Apply TCP keepalive to this transport, if it is a TCP connection.

A no-op for Unix socket transports (keepalive is a TCP-layer feature). Logs a warning and returns Ok(()) rather than failing if the platform does not support the requested keepalive interval.

Errors

Returns Error::Io if setting the TCP keepalive option fails.

Trait Implementations

impl Debug for Transport

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

Formats the value using the given formatter.