Struct mz_pgtest::PgConn

pub(crate) struct PgConn {
    pub(crate) stream: TcpStream,
    pub(crate) recv_buf: BytesMut,
    pub(crate) send_buf: BytesMut,
    pub(crate) timeout: Duration,
    pub(crate) verbose: bool,
}

Fields

stream: TcpStream

recv_buf: BytesMut

send_buf: BytesMut

timeout: Duration

verbose: bool

Implementations

impl PgConn

pub(crate) fn new<'a>( addr: &str, user: &'a str, timeout: Duration, verbose: bool, options: Vec<(&'a str, &'a str)>, ) -> Result<Self>

pub(crate) fn send<F: FnOnce(&mut BytesMut)>(&mut self, f: F) -> Result<()>

pub(crate) fn until( &mut self, until: Vec<&str>, err_field_typs: Vec<char>, ignore: BTreeSet<String>, ) -> Result<Vec<String>>

pub fn recv(&mut self) -> Result<(char, Message)>

Returns the PostgreSQL message format and the Message.

An error is returned if a new message is not received within the timeout.