Struct RestoreRegistry 

pub struct RestoreRegistry { /* private fields */ }

Tracks the inverse of every destructive change the fix has applied, so any terminal path can roll back half-applied state.

Cheaply cloneable (it is an Arc around a single mutex), so the same registry can be shared into the loop future and the Ctrl-C / drain arm of the outer select!. The mutex is tokio::sync::Mutex, which is non-poisoning — a panic inside the loop (caught by catch_unwind) does not wedge the registry, so the post-panic drain still works.

Implementations

impl RestoreRegistry

pub fn new() -> Self

pub async fn register(&self, op: RestoreOp) -> RestoreToken

Register an inverse op and return a token to resolve it later. Call this before applying the matching destructive change.

pub async fn mark_resolved(&self, token: RestoreToken)

Mark a previously-registered op resolved — the owning action restored the state itself, so the drain should skip it.

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

Run every still-unresolved restore op, best-effort. Snapshots the pending ops under the lock, releases the lock, then runs each with its own timeout so a wedged restore can’t stall the others. Returns a human-readable failure string per op that could not be restored (empty Vec = everything restored cleanly / nothing to do).

Resolved ops are cleared from the registry as they succeed, so a second drain (should one ever happen) is a no-op for already-restored state.

Trait Implementations

impl Clone for RestoreRegistry

fn clone(&self) -> RestoreRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for RestoreRegistry

fn default() -> RestoreRegistry

Returns the “default value” for a type.