Complete the migration.
(&mut self, actual_pause_us: u64)
| 184 | |
| 185 | /// Complete the migration. |
| 186 | pub fn complete(&mut self, actual_pause_us: u64) { |
| 187 | self.phase = MigrationPhase::Completed { |
| 188 | pause_duration_us: actual_pause_us, |
| 189 | }; |
| 190 | info!( |
| 191 | vshard = self.vshard_id, |
| 192 | pause_us = actual_pause_us, |
| 193 | "migration completed" |
| 194 | ); |
| 195 | } |
| 196 | |
| 197 | /// Mark migration as failed. Source remains authoritative. |
| 198 | pub fn fail(&mut self, reason: String) { |
no outgoing calls