Struct ContainerSupervisor 

pub struct ContainerSupervisor { /* private fields */ }

Container supervisor that monitors running containers and enforces error policies

Implementations

impl ContainerSupervisor

pub fn new(runtime: Arc<dyn Runtime + Send + Sync>) -> Self

Create a new container supervisor

pub fn with_config( runtime: Arc<dyn Runtime + Send + Sync>, config: SupervisorConfig, ) -> Self

Create a new container supervisor with custom configuration

pub fn set_isolate_callback<F>(&mut self, callback: F)

where F: Fn(&ContainerId) + Send + Sync + 'static,

Set the callback for container isolation (removing from load balancer)

pub async fn supervise(&self, container_id: &ContainerId, spec: &ServiceSpec)

Register a container for supervision

Arguments

• container_id - The container ID to supervise
• spec - The service specification (for error policies)

pub async fn unsupervise(&self, container_id: &ContainerId)

Remove a container from supervision

pub async fn get_state( &self, container_id: &ContainerId, ) -> Option<SupervisedState>

Get the current state of a supervised container

pub async fn get_container_info( &self, container_id: &ContainerId, ) -> Option<SupervisedContainer>

Get information about a supervised container

pub async fn list_supervised(&self) -> Vec<SupervisedContainer>

Get all supervised containers

pub async fn take_event_receiver(&self) -> Option<Receiver<SupervisorEvent>>

Get the event receiver for consuming supervisor events

Note: This takes ownership of the receiver. Only one consumer can receive events.

pub async fn run_loop(&self)

Start the supervision loop

This runs in the background, periodically checking container health and taking action based on the error policies.

pub fn shutdown(&self)

Signal the supervisor to stop

pub fn is_running(&self) -> bool

Check if the supervisor is currently running

pub async fn supervised_count(&self) -> usize

Get the number of supervised containers

pub async fn count_by_state(&self, state: SupervisedState) -> usize

Get the number of containers in a specific state