Struct SubsystemManager 

pub struct SubsystemManager { /* private fields */ }

Manager for coordinating multiple subsystems.

Implementations

impl SubsystemManager

pub fn new(shutdown_coordinator: ShutdownCoordinator) -> Self

Create a new subsystem manager.

pub fn enable_events(&self)

Enable coordination events. Subsequent state changes will emit SubsystemEvents.

Panics

Panics if the internal mutex is poisoned.

pub fn try_next_event(&self) -> Option<SubsystemEvent>

Try to fetch the next coordination event without blocking.

Panics

Panics if the internal mutex is poisoned.

pub fn register<S: Subsystem>(&self, subsystem: S) -> SubsystemId

Register a new subsystem with the manager.

Returns a unique ID for the registered subsystem.

Panics

Panics if the internal mutex is poisoned.

pub fn register_fn<F, Fut>(&self, name: &str, func: F) -> SubsystemId

where F: Fn(ShutdownHandle) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

Register a subsystem using a closure.

Panics

Panics if the internal mutex is poisoned.

pub fn register_closure<F>( &self, closure_subsystem: F, name: &str, ) -> SubsystemId

where F: Fn(ShutdownHandle) -> Pin<Box<dyn Future<Output = Result<()>> + Send>> + Send + Sync + 'static,

Register a closure as a subsystem.

Panics

Panics if the internal mutex is poisoned.

pub async fn start_subsystem(&self, id: SubsystemId) -> Result<()>

Start a specific subsystem.

Panics

Panics if the internal mutex is poisoned.

Errors

Returns a Error::subsystem error if the subsystem with the specified ID is not found.

pub async fn start_all(&self) -> Result<()>

Start all registered subsystems.

Panics

Panics if the internal mutex is poisoned.

Errors

Returns a Result<()> that resolves to Ok(()) even if individual subsystems fail to start. Errors from individual subsystems will be logged but won’t cause this method to return an error.

pub async fn stop_subsystem(&self, id: SubsystemId) -> Result<()>

Stop a specific subsystem gracefully.

Panics

Panics if the internal mutex is poisoned.

Errors

Returns a Error::subsystem error if the subsystem with the specified ID is not found.

pub async fn stop_all(&self) -> Result<()>

Stop all subsystems gracefully.

Panics

Panics if the internal mutex is poisoned.

Errors

Returns a Result<()> that resolves to Ok(()) even if individual subsystems fail to stop. Errors from individual subsystems will be logged but won’t cause this method to return an error.

pub async fn restart_subsystem(&self, id: SubsystemId) -> Result<()>

Restart a subsystem.

Panics

Panics if the internal mutex is poisoned.

Errors

Returns a Error::subsystem error if the subsystem with the specified ID is not found. May also return any error that occurs during the start operation.

pub fn get_stats(&self) -> SubsystemStats

Get statistics about all subsystems.

Panics

Panics if the subsystem mutex is poisoned.

pub fn get_subsystem_metadata( &self, id: SubsystemId, ) -> Option<SubsystemMetadata>

Get metadata for a specific subsystem.

Panics

Panics if the subsystem mutex is poisoned.

Returns None if the subsystem with the specified ID is not found.

pub fn get_all_metadata(&self) -> Vec<SubsystemMetadata>

Get all metadata for all subsystems.

Panics

Panics if the subsystem mutex is poisoned.

pub fn run_health_checks(&self) -> Vec<(SubsystemId, String, bool)>

Run health checks on all subsystems and return the results.

Panics

Panics if the subsystem mutex is poisoned.

impl SubsystemManager

pub fn subscribe_events(&self) -> Option<Receiver<SubsystemEvent>>

Subscribe to subsystem coordination events (lock-free backend only).

Returns a cloned receiver to the shared event stream when the lockfree-coordination feature is enabled and events have been previously enabled via enable_events().

Panics

Panics if the internal mutex is poisoned.

Trait Implementations

impl Clone for SubsystemManager

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.