Struct WorkloadStateMachine 

pub struct WorkloadStateMachine { /* private fields */ }

The state machine. Holds a map of tracked workloads keyed by workload_id. Drives transitions on each tick.

Implementations

impl WorkloadStateMachine

pub fn new(config: QuorumConfig) -> Self

pub fn track(&mut self, workload: DurableWorkload)

pub fn untrack(&mut self, workload_id: u32)

pub fn state_of(&self, workload_id: u32) -> Option<&WorkloadState>

pub fn workload(&self, workload_id: u32) -> Option<&DurableWorkload>

pub fn tick( &mut self, now: u64, observations: &[HeartbeatObservation], ) -> Vec<StateMachineEvent>

Apply observations and advance every tracked workload. Returns the side-effects the controller must perform.

pub fn notify_respawn_failed(&mut self, workload_id: u32, reason: &str)

Controller reports that a respawn attempt for a workload failed. The state machine either retries (if attempts remain) or marks the workload Failed.

pub fn notify_respawn_succeeded(&mut self, workload_id: u32, now: u64)

Controller reports that a respawn attempt succeeded. State transitions back to Live (heartbeats from the new container will keep it there).