Skip to main content

spawn_snapshot_watcher

Function spawn_snapshot_watcher 

Source
pub fn spawn_snapshot_watcher(
    db: Arc<LaminarDB>,
    store: Arc<AssignmentSnapshotStore>,
    registry: Arc<VnodeRegistry>,
    shutdown: CancellationToken,
    config: RebalanceConfig,
    controller: Option<Arc<ClusterController>>,
) -> JoinHandle<()>
Expand description

Spawn the per-node snapshot watcher. Exits on shutdown.

ยงPanics

The spawned watcher panics if an already-validated draining snapshot lacks its transition.