Struct convergence::connection::Connection

pub struct Connection<E: Engine> { /* fields omitted */ }

Describes a connection using a specific engine. Contains connection state including prepared statements and portals.

Implementations

impl<E: Engine> Connection<E>

pub fn new(engine: E) -> Self

Create a new connection from an engine instance.

pub async fn run(
    &mut self,
    stream: impl AsyncRead + AsyncWrite + Unpin
) -> Result<(), ConnectionError>

Given a stream (typically TCP), extract Postgres protocol messages and respond accordingly. This function only returns when the connection is closed (either gracefully or due to an error).