Mark migration as failed. Source remains authoritative.
(&mut self, reason: String)
| 196 | |
| 197 | /// Mark migration as failed. Source remains authoritative. |
| 198 | pub fn fail(&mut self, reason: String) { |
| 199 | warn!( |
| 200 | vshard = self.vshard_id, |
| 201 | reason = %reason, |
| 202 | "migration failed, source remains authoritative" |
| 203 | ); |
| 204 | self.phase = MigrationPhase::Failed { reason }; |
| 205 | } |
| 206 | |
| 207 | pub fn is_active(&self) -> bool { |
| 208 | !matches!( |
no outgoing calls