Enum Transport 

#[non_exhaustive]
pub enum Transport {
    Tcp(TcpVariant),
    Unix(UnixStream),
}

Transport layer abstraction

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future 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 WireError if the TCP connection to host:port 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 WireError::Io if the TCP connection or TLS handshake fails. Returns WireError::Config if the server rejects the SSL request.

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

Connect via Unix socket

Errors

Returns WireError if the Unix domain socket connection to path fails.

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

Write bytes to the transport

Errors

Returns WireError if the underlying I/O write fails.

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

Flush the transport

Errors

Returns WireError if the underlying I/O flush fails.

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

Read bytes into buffer

Errors

Returns WireError if the underlying I/O read fails.

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

Shutdown the transport

Errors

Returns WireError if the underlying I/O shutdown 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 WireError if setting the socket keepalive options fails on a TCP transport.

Trait Implementations

impl Debug for Transport

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

Formats the value using the given formatter.