Struct StreamSupervisor 

pub struct StreamSupervisor { /* private fields */ }

Supervises stream workers and restarts them on failure.

Tracks worker health, enforces restart limits, and optionally propagates failures to sibling workers (one-for-all supervision strategy).

Implementations

impl StreamSupervisor

pub fn new(config: SupervisorConfig) -> Self

Creates a new supervisor with the given configuration.

pub fn register_worker(&self, worker_id: impl Into<String>)

Registers a worker with the supervisor.

pub fn report_failure( &self, worker_id: &str, reason: &str, ) -> FaultResult<WorkerStatus>

Notifies the supervisor that a worker has failed.

The supervisor will attempt to restart the worker unless the restart limit has been reached.

Returns the new worker status.

pub fn acknowledge_restart(&self, worker_id: &str) -> FaultResult<()>

Acknowledges that a worker has successfully restarted.

pub fn stop_worker(&self, worker_id: &str) -> FaultResult<()>

Stops a worker intentionally.

pub fn worker_status(&self, worker_id: &str) -> Option<WorkerStatus>

Returns the current status of a worker.

pub fn workers_with_status(&self, status: &WorkerStatus) -> Vec<String>

Returns all workers whose status matches the given status.

pub fn stats(&self) -> SupervisorStats

Returns supervisor statistics.

pub fn restart_history(&self) -> Vec<RestartRecord>

Returns the full restart history.