Struct Buffered 

pub struct Buffered<S, D = Backend> { /* private fields */ }

Transport wrapper which retains bytes until each write has completed.

Implementations

impl<S> Buffered<S, Backend>

pub fn new(io: S) -> Self

Wraps an upstream-facing transport which receives backend messages.

pub fn with_max_frame_len(io: S, max_frame_len: usize) -> Result<Self>

Creates a backend-facing transport with a bounded tagged-frame size.

Errors

Returns an error when the limit is outside PostgreSQL’s frame range.

impl<S> Buffered<S, Frontend>

pub fn new_frontend(io: S) -> Self

Wraps a client-facing transport which receives frontend messages.

pub fn with_max_frame_len_frontend(io: S, max_frame_len: usize) -> Result<Self>

Creates a frontend-facing transport with a bounded tagged-frame size.

Errors

Returns an error when the limit is outside PostgreSQL’s frame range.

pub fn with_limits_frontend( io: S, max_frame_len: usize, max_pre_startup_packet_len: usize, ) -> Result<Self>

Creates a frontend-facing transport with bounded tagged and pre-startup packets.

Errors

Returns an error when either limit is outside PostgreSQL’s framing range.

impl<S, D> Buffered<S, D>

pub fn push(&mut self, frame: Frame) -> Result<()>

Encodes a frame synchronously into the outbound buffer.

Errors

Returns an error when the frame is too large to encode.

pub fn pending(&self) -> &[u8]

Returns encoded bytes which have not yet been fully written.

pub fn into_inner(self) -> S

Removes buffering and returns the underlying I/O transport.

pub const fn demux(&self) -> &Demux

Returns the backend asynchronous-message demultiplexer.

pub const fn demux_mut(&mut self) -> &mut Demux

Returns mutable access to the backend asynchronous-message demultiplexer.

impl<S: AsyncWrite + Unpin, D> Buffered<S, D>

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

Writes all buffered bytes without consuming the connection.

Completed partial writes are removed immediately. If this future is cancelled, the connection remains owned by the caller and all unwritten bytes remain buffered for the next call.

Errors

Returns the underlying transport’s write error or WriteZero.

impl<S: AsyncRead + Unpin, D: Direction> Buffered<S, D>

pub async fn receive_wire(&mut self) -> Result<D::Message>

Receives one typed message in this transport’s inbound direction.

Errors

Returns decoding and underlying transport read errors, or UnexpectedEof.

impl<S: AsyncRead + Unpin> Buffered<S, Frontend>

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

Receives one raw first packet before tagged frontend framing begins.

Errors

Returns malformed pre-startup data and underlying transport read errors.

impl<S: AsyncRead + Unpin> Buffered<S, Backend>

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

Receives one decoded backend message while retaining partial input.

Errors

Returns decoding and underlying transport read errors, or UnexpectedEof.

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

Receives the next protocol-advancing message through the async demux.

Errors

Returns decoding and underlying transport read errors, or UnexpectedEof.

pub fn project_backend( &mut self, message: BackendMessage, ) -> Option<SessionItem>

Projects an inspected or modified backend message into the session stream.

Trait Implementations

impl<S: Debug, D: Debug> Debug for Buffered<S, D>

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

Formats the value using the given formatter.

impl<S: TlsServerEndPoint, D> TlsServerEndPoint for Buffered<S, D>

fn tls_server_end_point(&self) -> &[u8]

Returns the RFC 5929 channel-binding bytes derived from the peer certificate.