Struct ClientConnection 

pub struct ClientConnection<Transport, State, Cleanliness = ConnectionClean, Evidence = (), Handler = IdentityHandler> { /* private fields */ }

Operational client-role connection.

Implementations

impl<Transport, State, Cleanliness, Evidence, Handler> ClientConnection<Transport, State, Cleanliness, Evidence, Handler>

pub const fn context(&self) -> &ClientConnectionContext<Evidence>

Returns immutable connection facts.

pub const fn state(&self) -> &State

Returns the caller-owned connection state.

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

where Transport: AsyncRead + Unpin, Handler: ClientMiddleware<State, ClientConnectionContext<Evidence>>,

Receives one backend message at the operational inspection boundary.

Errors

Returns a transport, decoding, or configured frame-limit error.

pub fn into_parts( self, ) -> (Transport, State, Handler, ClientConnectionContext<Evidence>)

Recovers every owned connection part deliberately.

impl<Transport, State, Cleanliness, Evidence, Handler> ClientConnection<Transport, State, Cleanliness, Evidence, Handler>

where Transport: AsyncRead + AsyncWrite + Unpin, Handler: ClientMiddleware<State, ClientConnectionContext<Evidence>>,

pub async fn simple_query( self, query: &[u8], ) -> Result<(ClientConnection<Transport, State, ConnectionChanged, Evidence, Handler>, Vec<BackendMessage>), QueryError>

Executes a simple query through typed completion back to operational readiness.

The returned connection is conservatively marked dirty because arbitrary SQL may retain session-local state.

Errors

Returns an error for invalid query text, I/O or framing failure, an illegal peer transition, COPY entry, or a backend error response.