Install the shared scan-quiesce registry. Called once by the server bootstrap in `main.rs` after `SharedState::open`.
(
&mut self,
quiesce: std::sync::Arc<crate::bridge::quiesce::CollectionQuiesce>,
)
| 11 | /// Install the shared scan-quiesce registry. Called once by the |
| 12 | /// server bootstrap in `main.rs` after `SharedState::open`. |
| 13 | pub fn set_quiesce( |
| 14 | &mut self, |
| 15 | quiesce: std::sync::Arc<crate::bridge::quiesce::CollectionQuiesce>, |
| 16 | ) { |
| 17 | self.quiesce = Some(quiesce); |
| 18 | } |
| 19 | |
| 20 | /// Acquire a scan guard for `(tid, collection)`. Returns `Ok(None)` |
| 21 | /// if no quiesce registry is installed (e.g. in tests) — callers |