Struct ReplicationConnection 

pub struct ReplicationConnection { /* private fields */ }

Implementations

impl ReplicationConnection

pub async fn connect( host: &str, port: u16, database: &str, user: &str, password: &str, ) -> Result<Self>

pub async fn identify_system(&mut self) -> Result<HashMap<String, String>>

pub async fn create_replication_slot( &mut self, slot_name: &str, temporary: bool, ) -> Result<ReplicationSlotInfo>

pub async fn get_replication_slot_info( &mut self, slot_name: &str, ) -> Result<ReplicationSlotInfo>

pub async fn start_replication( &mut self, slot_name: &str, start_lsn: Option<u64>, options: HashMap<String, String>, ) -> Result<()>

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

pub async fn send_standby_status( &mut self, status: StandbyStatusUpdate, ) -> Result<()>

pub async fn close(self) -> Result<()>