Enum mz_pgwire_common::Conn

pub enum Conn<A> {
    Unencrypted(A),
    Ssl(SslStream<A>),
}

Variants

Unencrypted(A)

Ssl(SslStream<A>)

Implementations

impl<A> Conn<A>

pub fn inner_mut(&mut self) -> &mut A

pub fn ensure_tls_compatibility( &self, tls_mode: &Option<TlsMode>, ) -> Result<(), ErrorResponse>

Returns an error if tls_mode is incompatible with this connection’s stream type.

Trait Implementations

impl<A> AsyncRead for Conn<A>

where A: AsyncRead + AsyncWrite + Unpin,

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.

impl<A> AsyncReady for Conn<A>

where A: AsyncRead + AsyncWrite + AsyncReady + Sync + Unpin,

fn ready<'life0, 'async_trait>( &'life0 self, interest: Interest, ) -> Pin<Box<dyn Future<Output = Result<Ready>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Checks for IO readiness.

impl<A> AsyncWrite for Conn<A>

where A: AsyncRead + AsyncWrite + Unpin,

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize>>

Attempt to write bytes from buf into the object.

fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Attempts to flush the object, ensuring that any buffered data reach their destination.

fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<()>>

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Like poll_write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.

impl<A: Debug> Debug for Conn<A>

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

Formats the value using the given formatter.