Struct ProcessSupervisor 

pub struct ProcessSupervisor { /* private fields */ }

Implementations

impl ProcessSupervisor

pub fn new(stream_tx: Sender<StreamItem>) -> Self

pub fn reconcile( &mut self, desired: Vec<ProcessSpec>, ) -> ReconcileErrors<ProcessIdentity, SpawnError>

pub fn get(&self, identity: &ProcessIdentity) -> Option<&ProcessState>

pub fn iter(&self) -> impl Iterator<Item = (&ProcessIdentity, &ProcessState)>

pub fn shutdown_all(&mut self) -> ReconcileErrors<ProcessIdentity, SpawnError>

Drains every tracked process by reconciling against an empty desired set, driving each one through Lifecycle::exit (SIGTERM, then SIGKILL after SHUTDOWN_GRACE_PERIOD).

Dropping a ProcessSupervisor does not do this on its own: Child’s own Drop never kills its process, so call this explicitly before the owning program exits or re-execs — otherwise every process it’s still tracking is abandoned rather than torn down.