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