Struct RecoveryManager 

pub struct RecoveryManager { /* private fields */ }

Global recovery manager

Implementations

impl RecoveryManager

pub fn new() -> Self

Create new recovery manager

pub async fn set_default_policy(&self, policy: RecoveryPolicy)

Set default recovery policy

pub async fn set_policy(&self, node_id: &str, policy: RecoveryPolicy)

Set recovery policy for a specific node

pub async fn get_policy(&self, node_id: &str) -> RecoveryPolicy

Get recovery policy for a node

pub async fn get_history(&self, node_id: &str) -> RecoveryHistory

Get recovery history for a node

pub async fn record_attempt(&self, node_id: &str, attempt: RecoveryAttempt)

Record a recovery attempt

pub async fn determine_action( &self, node_id: &str, current_state: NodeState, ) -> RecoveryAction

Determine recovery action for a node

pub async fn get_restart_delay(&self, node_id: &str) -> Duration

Calculate delay before next restart

pub async fn mark_degraded(&self, node_id: &str)

Mark node as degraded

pub async fn is_degraded(&self, node_id: &str) -> bool

Check if node is degraded

pub async fn list_degraded(&self) -> Vec<String>

Get all degraded nodes

pub async fn clear_degraded(&self, node_id: &str)

Clear degraded status

pub async fn get_stats(&self) -> RecoveryStats

Get recovery statistics

Trait Implementations

impl Default for RecoveryManager

fn default() -> Self

Returns the “default value” for a type.