Struct RuntimeControlState 

pub struct RuntimeControlState {
    pub orphan_count: u64,
    /* private fields */
}

Mutable state owned by the control loop.

Fields

orphan_count: u64

Active count of orphaned child tasks that could not be stopped within policy timeouts.

Implementations

impl RuntimeControlState

pub fn new( spec: SupervisorSpec, command_sender: Sender<RuntimeLoopMessage>, observability: Arc<Mutex<ObservabilityPipeline>>, ) -> Result<Self, SupervisorError>

Creates control state from a supervisor specification.

Arguments

• spec: Supervisor declaration that owns children and strategy.
• command_sender: Sender used by child start_counts to report exits.

Returns

Returns a RuntimeControlState value.

pub fn new_with_factory_registry( spec: SupervisorSpec, command_sender: Sender<RuntimeLoopMessage>, observability: Arc<Mutex<ObservabilityPipeline>>, task_factory_registry: TaskFactoryRegistry, ) -> Result<Self, SupervisorError>

Creates control state with a task factory registry for dynamic children.

Arguments

• spec: Supervisor declaration that owns children and strategy.
• command_sender: Sender used by child start_counts to report exits.
• observability: Shared observability pipeline.
• task_factory_registry: Registry used by add_child declarations.

Returns

Returns a RuntimeControlState value.

pub async fn start_declared_children(&mut self)

Starts every declared child in supervisor startup order.

Children are spawned in topological order (dependencies first), but readiness waiting (a child’s dependencies must be ready before it starts) is not yet implemented — this is tracked for a future slice. As a result, children that declare dependencies will start in the correct order but dependencies must report ready before the dependent child starts. This prevents downstream workers from beginning execution before their required services (database, cache, message queue) are ready to serve requests.

Arguments

This function has no arguments.

Returns

This function does not return a value.

pub fn set_exit_handler(&mut self, handler: Arc<dyn ExitHandler>)

Records an active attempt after spawn_once so exit routing matches registry identities.

Immediate spawns run this inline; delayed backoff spawns deliver the same handle through ChildStartMessage::DelayedSpawnAttached so activate_instance stays on the control loop.

Arguments

• child_id: Stable child owning the spawned attempt.
• path: Supervisor path used when inserting placeholder runtime records.
• generation: Generation pinned from the registry ChildRuntime passed to spawn_once.
• attempt: Attempt counter pinned from the same registry record.
• handle: Runner handle carrying cancellation and completion endpoints.

Returns

Sets the exit handler strategy for process termination.

The default handler calls std::process::exit(1). Tests can swap in a stub that records the exit request without terminating the process.

Arguments

• handler: Exit handler implementation.

Returns

This function does not return a value.

pub async fn execute_control( &mut self, command: ControlCommand, event_sender: &Sender<String>, ) -> Result<CommandResult, SupervisorError>

Executes one control command.

Arguments

• command: Command received by the runtime.
• event_sender: Event channel used for lifecycle text.

Returns

Returns a command result.

pub fn handle_child_exit( &mut self, report: ChildRunReport, event_sender: &Sender<String>, )

Applies policy to a completed child child_start_count.

Arguments

• report: Completed child child_start_count report.
• event_sender: Event channel used for lifecycle text.

Returns

This function does not return a value.

pub fn handle_child_start_failed( &mut self, child_id: ChildId, message: String, event_sender: &Sender<String>, )

Records a failed child start.

Arguments

• child_id: Child identifier whose child_start_count failed.
• message: Diagnostic error message.
• event_sender: Event channel used for lifecycle text.

Returns

This function does not return a value.

Trait Implementations

impl Debug for RuntimeControlState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.