Struct RecoveryManager 

pub struct RecoveryManager {
    config: RwLock<RawRwLock, RecoveryConfig>,
    handlers: RwLock<RawRwLock, HashMap<RecoveryPolicy, Arc<dyn Fn(&RecoveryAction) -> Pin<Box<dyn Future<Output = RecoveryResult> + Send>> + Send + Sync>>>,
    history: RwLock<RawRwLock, HashMap<KernelId, Vec<RecoveryResult>>>,
    attempts: RwLock<RawRwLock, HashMap<KernelId, u32>>,
    last_recovery: RwLock<RawRwLock, HashMap<KernelId, Instant>>,
    stats: RecoveryStats,
    enabled: AtomicBool,
}

Manager for automatic kernel recovery.

Fields

config: RwLock<RawRwLock, RecoveryConfig>

handlers: RwLock<RawRwLock, HashMap<RecoveryPolicy, Arc<dyn Fn(&RecoveryAction) -> Pin<Box<dyn Future<Output = RecoveryResult> + Send>> + Send + Sync>>>

history: RwLock<RawRwLock, HashMap<KernelId, Vec<RecoveryResult>>>

attempts: RwLock<RawRwLock, HashMap<KernelId, u32>>

last_recovery: RwLock<RawRwLock, HashMap<KernelId, Instant>>

stats: RecoveryStats

enabled: AtomicBool

Implementations

impl RecoveryManager

pub fn new() -> RecoveryManager

Create a new recovery manager with default config.

pub fn with_config(config: RecoveryConfig) -> RecoveryManager

Create with specific configuration.

pub fn set_enabled(&self, enabled: bool)

Enable/disable automatic recovery.

pub fn is_enabled(&self) -> bool

Check if recovery is enabled.

pub fn set_config(&self, config: RecoveryConfig)

Update configuration.

pub fn config(&self) -> RecoveryConfig

Get current configuration.

pub fn register_handler( &self, policy: RecoveryPolicy, handler: Arc<dyn Fn(&RecoveryAction) -> Pin<Box<dyn Future<Output = RecoveryResult> + Send>> + Send + Sync>, )

Register a recovery handler.

pub fn should_recover(&self, kernel_id: &KernelId) -> bool

Check if recovery should be attempted (respects cooldown).

pub fn determine_action( &self, kernel_id: &KernelId, failure_type: FailureType, ) -> RecoveryAction

Determine recovery action for a failure.

pub async fn recover(&self, action: RecoveryAction) -> RecoveryResult

Execute recovery for a kernel.

pub fn get_history(&self, kernel_id: &KernelId) -> Vec<RecoveryResult>

Get recovery history for a kernel.

pub fn clear_history(&self)

Clear recovery history.

pub fn stats(&self) -> RecoveryStatsSnapshot

Get statistics snapshot.

Trait Implementations

impl Default for RecoveryManager

fn default() -> RecoveryManager

Returns the “default value” for a type.