Transition to Phase 2: WAL Catch-up.
(&mut self, start_lsn: u64, source_lsn: u64)
| 115 | |
| 116 | /// Transition to Phase 2: WAL Catch-up. |
| 117 | pub fn start_wal_catchup(&mut self, start_lsn: u64, source_lsn: u64) { |
| 118 | self.phase = MigrationPhase::WalCatchUp { |
| 119 | start_lsn, |
| 120 | current_lsn: start_lsn, |
| 121 | source_lsn, |
| 122 | }; |
| 123 | info!( |
| 124 | vshard = self.vshard_id, |
| 125 | start_lsn, |
| 126 | source_lsn, |
| 127 | lag = source_lsn - start_lsn, |
| 128 | "starting wal catch-up" |
| 129 | ); |
| 130 | } |
| 131 | |
| 132 | /// Update WAL catch-up progress. |
| 133 | pub fn update_wal_catchup(&mut self, current_lsn: u64, source_lsn: u64) { |
no outgoing calls