Skip to main content

supervised_spawn

Function supervised_spawn 

Source
pub fn supervised_spawn<S: Scanner>(
    scanner: Arc<S>,
    client: Client,
    num_partitions: u16,
    shutdown: Receiver<bool>,
    metrics: Arc<Metrics>,
) -> JoinHandle<()>
Expand description

Spawn a supervised scanner that restarts on panic.

  • Clean shutdown (via watch channel): exits normally.
  • Panic: logs, sleeps 5s, increments restart counter, re-spawns.