Struct ReplicationConnection 

pub struct ReplicationConnection {
    pub server_version: Option<String>,
    /* private fields */
}

Fields

server_version: Option<String>

Implementations

impl ReplicationConnection

pub async fn connect( info: &ConnectionInfo, safety: &SafetyConfig, timeout: Duration, ) -> Result<Self>

Open a logical-replication connection to info.dbname.

pub fn set_max_message_bytes(&mut self, bytes: usize)

Refuse backend messages larger than bytes (see resources.max_message_bytes).

pub async fn simple_query(&mut self, sql: &str) -> Result<SimpleResult>

Run a simple-query command (replication commands or SQL) and collect the result.

pub async fn start_replication(&mut self, command: &str) -> Result<()>

Issue START_REPLICATION ... and switch to CopyBoth mode.

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

Next CopyData payload from the server. Cancel-safe: a partially received frame stays buffered. Returns an error when the stream ends.

pub async fn send_copy_data(&mut self, payload: &[u8]) -> Result<()>

Send a CopyData frame (standby status update) to the server.

pub async fn close(self)