Struct StabilityMonitor 

pub struct StabilityMonitor {
    pub energy_history: Vec<f32>,
    pub attempt_count: usize,
    pub stable: bool,
    pub stability_epsilon: f32,
    pub max_retries: usize,
    pub retry_policy: RetryPolicy,
}

Stability monitor for tracking Lyapunov Energy

Fields

energy_history: Vec<f32>

History of V(x) values

attempt_count: usize

Number of convergence attempts

stable: bool

Whether the node has converged to stability

stability_epsilon: f32

Stability threshold (epsilon)

max_retries: usize

Maximum retry attempts before escalation (legacy, use retry_policy)

retry_policy: RetryPolicy

Retry policy with PSP-4 compliant limits

Implementations

impl StabilityMonitor

pub fn new() -> StabilityMonitor

Create with default epsilon = 0.1

pub fn record_energy(&mut self, energy: f32)

Record a new energy value

pub fn record_failure(&mut self, error_type: ErrorType)

Record a failure with error type

pub fn should_escalate(&self) -> bool

Check if we should escalate (exceeded retries without stability)

pub fn should_escalate_for(&self, error_type: ErrorType) -> bool

Check if we should escalate for a specific error type

pub fn remaining_attempts(&self) -> usize

Get remaining attempts for current error type

pub fn current_energy(&self) -> f32

Get the current energy level (last recorded)

pub fn is_converging(&self) -> bool

Check if energy is decreasing (converging)

pub fn reset_for_replan(&mut self)

Reset monitor state for a subgraph replan, preserving history but clearing attempt count and stability flag so the node can be retried.

Trait Implementations

impl Clone for StabilityMonitor

fn clone(&self) -> StabilityMonitor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StabilityMonitor

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

Formats the value using the given formatter.

impl Default for StabilityMonitor

fn default() -> StabilityMonitor

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for StabilityMonitor

fn deserialize<__D>( __deserializer: __D, ) -> Result<StabilityMonitor, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StabilityMonitor

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.