pub async fn setup_raw_persist( persist: PersistClient, id: ShardId, num_writers: usize, num_readers: usize, ) -> Result<(Vec<RawBenchmarkWriter>, Vec<Listen<Vec<u8>, Vec<u8>, u64, i64>>), Error>