(&mut self, aid: &ArrayId, cells: Vec<ArrayPutCell>, lsn: u64)
| 128 | } |
| 129 | |
| 130 | fn put(&mut self, aid: &ArrayId, cells: Vec<ArrayPutCell>, lsn: u64) { |
| 131 | let bytes = zerompk::to_msgpack_vec(&cells).unwrap(); |
| 132 | let r = self.send(ArrayOp::Put { |
| 133 | array_id: aid.clone(), |
| 134 | cells_msgpack: bytes, |
| 135 | wal_lsn: lsn, |
| 136 | }); |
| 137 | assert_eq!(r.status, Status::Ok, "put failed: {r:?}"); |
| 138 | } |
| 139 | |
| 140 | fn flush(&mut self, aid: &ArrayId) { |
| 141 | let r = self.send(ArrayOp::Flush { |
no test coverage detected