async fn ensure_replication_slot( client: &Client, slot: &str, timeout: Duration, ) -> Result<(), TransientError>