(&self, mv: PlannedMove)
| 67 | #[async_trait] |
| 68 | impl MigrationDispatcher for RecordingDispatcher { |
| 69 | async fn dispatch(&self, mv: PlannedMove) -> Result<()> { |
| 70 | self.calls.lock().unwrap().push(mv); |
| 71 | self.any_call.store(true, Ordering::SeqCst); |
| 72 | Ok(()) |
| 73 | } |
| 74 | } |
| 75 | |
| 76 | pub fn lm(id: u64, v: u32, bytes_mib: u64, w: f64, r: f64) -> LoadMetrics { |