Struct WirePoolable 

pub struct WirePoolable(pub WireConn);

Newtype wrapper around pg_wired::WireConn that implements Poolable.

Tuple Fields

0: WireConn

Methods from Deref<Target = WireConn>

pub fn pid(&self) -> i32

Backend process ID assigned by the server. Useful for logging and for building a cancel token. The secret key that pairs with this PID is intentionally not exposed; use cancel_token() to obtain a token that can send a cancel request.

pub fn auth_mechanism(&self) -> &'static str

Authentication mechanism the server selected during startup.

Returns one of "trust", "cleartext", "md5", "SCRAM-SHA-256", or "SCRAM-SHA-256-PLUS". "SCRAM-SHA-256-PLUS" confirms that tls-server-end-point channel binding was negotiated.

pub fn has_pending_data(&self) -> bool

Check if the connection has unconsumed data in the receive buffer.

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

Send a raw buffer to the server (one write syscall).

pub async fn recv_msg(&mut self) -> Result<BackendMsg, PgWireError>

Read one complete backend message from the connection. Uses an internal buffer to minimize read() syscalls.

pub async fn collect_rows( &mut self, ) -> Result<(Vec<RawRow>, String), PgWireError>

Receive messages until ReadyForQuery, collecting DataRows. Returns (rows, command_tag).

pub async fn describe_statement( &mut self, sql: &str, ) -> Result<(Vec<u32>, Vec<FieldDescription>), PgWireError>

Describe a SQL statement: sends Parse + Describe Statement + Sync, returns (parameter type OIDs, column field descriptions). Used by compile-time query checking macros.

pub async fn drain_until_ready(&mut self) -> Result<(), PgWireError>

Drain messages until ReadyForQuery (error recovery). Also attempts to parse any remaining data in the receive buffer before declaring the connection closed.

Trait Implementations

impl Deref for WirePoolable

type Target = WireConn

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for WirePoolable

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl Poolable for WirePoolable

type Error = PgWireError

The error type for connection operations.

async fn connect( addr: &str, user: &str, password: &str, database: &str, ) -> Result<Self, Self::Error>

Create a new connection to the database.

fn has_pending_data(&self) -> bool

Check if the connection has unconsumed data (is in a corrupted state).

fn reset(&self) -> impl Future<Output = bool> + Send

Reset the connection to a clean state before returning to the pool. Implementations should send DISCARD ALL or equivalent to clear session state (transactions, SET variables, temp tables, prepared statements). Returns false if the reset failed and the connection should be destroyed.