(ids: Vec<u64>)
| 483 | } |
| 484 | |
| 485 | pub fn generate_insert_commands(ids: Vec<u64>) -> Bytes { |
| 486 | let mut buffer = BytesMut::new(); |
| 487 | |
| 488 | for id in ids { |
| 489 | let cmd = WriteCommand::insert(safe_kv_bytes(id), safe_kv_bytes(id)); |
| 490 | cmd.encode(&mut buffer).expect("Failed to encode insert command"); |
| 491 | } |
| 492 | |
| 493 | buffer.freeze() |
| 494 | } |
| 495 | |
| 496 | pub async fn reset(case_name: &str) -> std::result::Result<(), ClientApiError> { |
| 497 | let root_path = get_root_path(); |
no test coverage detected