Struct Supervisor 

pub struct Supervisor { /* private fields */ }

Supervisor for managing node lifecycle

Implementations

impl Supervisor

pub fn new( health_checker: Arc<HealthChecker>, shutdown: ShutdownHandle, restart_policy: RestartPolicy, ) -> Self

Create a new supervisor

pub fn launch_node(&self, node: Box<dyn NodeRunner>) -> NodeHandle

Launch and supervise a node

pub fn launch_nodes(&self, nodes: Vec<Box<dyn NodeRunner>>) -> Vec<NodeHandle>

Launch multiple nodes

pub fn health_checker(&self) -> &Arc<HealthChecker>

Get the health checker

pub fn shutdown(&self) -> &ShutdownHandle

Get the shutdown handle

pub async fn start_node(&self, name: &str) -> Result<()>

Start a node by name (for lifecycle management)

Note: This is a stub implementation for the lifecycle system. Full implementation requires node registry or factory pattern.

Arguments

• name - Name of the node to start

Errors

Returns error if node cannot be found or started

pub async fn stop_node(&self, name: &str) -> Result<()>

Stop a node by name (for lifecycle management)

Arguments

• name - Name of the node to stop

Errors

Returns error if node cannot be found or stopped

pub async fn get_running_nodes(&self) -> Vec<String>

Get list of currently running nodes

Returns the names of all nodes being supervised

Trait Implementations

impl SupervisorTrait for Supervisor

Implement the SupervisorTrait for Supervisor

fn start_node<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Start a node by name

fn stop_node<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Stop a node by name

fn get_running_nodes(&self) -> Vec<String>

Get list of running nodes