Update base copy progress.
(&mut self, bytes_transferred: u64)
| 105 | |
| 106 | /// Update base copy progress. |
| 107 | pub fn update_base_copy(&mut self, bytes_transferred: u64) { |
| 108 | if let MigrationPhase::BaseCopy { bytes_total, .. } = self.phase { |
| 109 | self.phase = MigrationPhase::BaseCopy { |
| 110 | bytes_transferred, |
| 111 | bytes_total, |
| 112 | }; |
| 113 | } |
| 114 | } |
| 115 | |
| 116 | /// Transition to Phase 2: WAL Catch-up. |
| 117 | pub fn start_wal_catchup(&mut self, start_lsn: u64, source_lsn: u64) { |
no outgoing calls