Struct RecoveryGate 

pub struct RecoveryGate { /* private fields */ }

The one slot per session that background work has to hold.

It is shared rather than per-coordinator: a recovery copy and a worker upgrade both act on a session’s live worker, so only one of them may run at a time, and a foreground lifecycle operation preempts whichever it is.

Implementations

impl RecoveryGate

pub fn reserve(self: &Arc<Self>, session_id: &str) -> RecoveryReservation

pub fn try_start(&self, session_id: &str) -> Option<Arc<AtomicBool>>

Claims the session for background work and returns the cancel flag that work must watch, or None when other work or a reservation already holds it.

pub fn finish(&self, session_id: &str)

pub fn subscribe(&self) -> Receiver<BTreeSet<String>>

pub fn is_busy(&self, session_id: &str) -> bool

pub fn cancel_busy(&self, session_id: &str)

Asks the in-flight copy for this session, if any, to stop.

pub fn cancel_all(&self)

Asks every in-flight copy to stop, used when a coordinator shuts down.

pub fn busy_sessions(&self) -> BTreeSet<String>

Trait Implementations

impl Default for RecoveryGate

fn default() -> Self

Returns the “default value” for a type.