Struct SupervisorWatchdog 

pub struct SupervisorWatchdog { /* private fields */ }

Atomic watchdog state shared by reconcile, health, and watchdog threads.

Implementations

impl SupervisorWatchdog

pub fn new(config: WatchdogConfig, created_at_ms: u64) -> SupervisorResult<Self>

Creates a watchdog with validated installation policy.

pub fn record_reconcile_started(&self, timestamp_ms: u64)

Records entry into one reconciliation cycle without taking a lock.

pub fn record_reconcile_completed(&self, timestamp_ms: u64) -> u64

Records successful completion and returns the new sequence.

pub fn evaluate( &self, timestamp_ms: u64, ) -> Option<(WatchdogState, WatchdogState)>

Evaluates progress and returns a state transition when one occurred.

pub fn mark_stopping(&self)

Marks watchdog shutdown without changing reconciliation counters.

pub fn mark_failed(&self)

Marks an unrecoverable watchdog failure.

pub fn config(&self) -> WatchdogConfig

Returns immutable watchdog policy.

pub fn state(&self) -> WatchdogState

Returns the current atomic watchdog state.

pub fn last_reconcile_at_ms(&self) -> u64

Returns the most recent reconciliation start or completion time.

pub fn reconcile_sequence(&self) -> u64

Returns the number of completed reconciliation cycles.

pub fn last_progress_at_ms(&self) -> u64

Returns the most recent completed reconciliation time.

pub fn stalled_for_ms(&self, timestamp_ms: u64) -> u64

Returns elapsed time without a completed reconciliation cycle.