Struct Supervisor 

pub struct Supervisor { /* private fields */ }

Supervisor that manages a set of processes

Implementations

impl Supervisor

pub fn new(config: SupervisorConfig) -> Self

Creates a new supervisor with the specified configuration

Arguments

• config - Supervisor configuration

Example

use rust_supervisor::{Supervisor, SupervisorConfig};
let supervisor = Supervisor::new(SupervisorConfig::default());

pub fn with_callback( config: SupervisorConfig, callback: Arc<dyn EventCallback>, ) -> Self

Creates a new supervisor with a custom event callback

pub fn add_process<F>(&mut self, name: &str, child_type: ChildType, factory: F)

where F: Fn() -> JoinHandle<()> + Send + 'static,

Adds a process to monitor

Arguments

• name - Unique process name
• child_type - Type of child (Permanent, Temporary, Transient)
• factory - Function that creates and starts the process

Example

use rust_supervisor::{Supervisor, SupervisorConfig, ChildType};
use std::thread;
 
let mut supervisor = Supervisor::new(SupervisorConfig::default());
supervisor.add_process("worker", ChildType::Permanent, || {
    thread::spawn(|| {
        // Worker code...
    })
});

pub fn add_process_with_shutdown<F>( &mut self, name: &str, child_type: ChildType, factory: F, shutdown_strategy: ShutdownStrategy, )

where F: Fn() -> JoinHandle<()> + Send + 'static,

Adds a process with custom shutdown strategy

pub fn add_dependency(&self, process: &str, depends_on: &str)

Declares a dependency between two processes

Arguments

• process - Name of the process that depends on another
• depends_on - Name of the process that the first one depends on

pub fn start_monitoring(self) -> Arc<Self>

where Self: Sized,

Starts monitoring processes

This method launches a monitoring thread that periodically checks the state of processes and restarts them according to the configured strategy.

Returns Arc for convenience chaining.

pub fn stop_process(&self, name: &str) -> bool

Manually stops a process with graceful shutdown

Arguments

• name - Name of the process to stop

Returns

true if the process was found and stopped, false otherwise

pub fn shutdown(&self)

Stops all processes gracefully

pub fn get_process_state(&self, name: &str) -> Option<ProcessState>

Gets the current state of a process

Arguments

• name - Process name

Returns

The process state, or None if the process doesn’t exist

pub fn get_restart_count(&self, name: &str) -> Option<usize>

Gets the restart count for a process

pub fn get_all_states(&self) -> HashMap<String, (ProcessState, usize)>

Gets all process states

pub fn get_shutdown_signal(&self, name: &str) -> Option<Arc<AtomicBool>>

Get the shutdown signal for a process (for graceful shutdown detection)