pub async fn connect_replication(conn: &str) -> Result<Client, Error>
Starts a replication connection to the upstream database