Struct Supervisor 

pub struct Supervisor { /* private fields */ }

Owns a pool of workers and supervises them.

Implementations

impl Supervisor

pub fn new(specs: Vec<WorkerSpec>) -> Self

pub fn rate_limit(self, max_restarts: u32, window: Duration) -> Self

pub fn cooldown(self, cooldown: Duration) -> Self

pub fn register_drain(&mut self, worker_id: &str) -> Option<Arc<Notify>>

Register a drain signal for a worker and return a handle to trigger it.

Call notify_one() on the returned Arc<Notify> to gracefully restart that specific worker. Must be called before run().

pub async fn run(self, drain: DrainController) -> Vec<WorkerInfo>

Run the supervision loop until drain begins, then return final snapshots.