Struct Supervisor 

pub struct Supervisor { /* private fields */ }

Builder/configuration for a supervised worker.

Implementations

impl Supervisor

pub fn new(name: impl Into<String>) -> Self

Create a supervisor for a worker with the given diagnostic name.

Defaults: base_backoff = 10ms, max_backoff = 1s.

pub fn base_backoff(self, d: Duration) -> Self

Override the initial post-panic backoff.

pub fn max_backoff(self, d: Duration) -> Self

Override the maximum post-panic backoff.

pub fn spawn<F>(self, running: Arc<AtomicBool>, body: F) -> SupervisedWorker

where F: FnMut() -> WorkerStep + Send + 'static,

Spawn the supervised worker.

The worker runs body repeatedly while running is true and the body keeps returning WorkerStep::Continue. Each call to body is isolated with catch_unwind; a panic is counted, the worker is marked unhealthy, a bounded backoff is applied, and the loop continues.