Struct RecoveryObserver 

pub struct RecoveryObserver {
    pub gate: Arc<RecoveryGate>,
    /* private fields */
}

Reports session activity to the recovery coordinator.

Reporting retains only the newest observation per session. Completed-turn frontiers are merged monotonically, so coalescing does not lose the boundary that makes a recovery copy due.

A caller that must know no copy can start uses RecoveryObserver::reserve rather than the queue: the reservation blocks a copy from starting whether or not queued observations have been read yet.

Fields

gate: Arc<RecoveryGate>

Implementations

impl RecoveryObserver

pub fn observe(&self, observation: RecoveryObservation)

Queues one observation for the coordinator. Returns as soon as the observation is queued; a stopped coordinator makes this a no-op.

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

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

Holds off any recovery copy for this session until the returned reservation is dropped. This, not the observation queue, is what a lifecycle operation relies on: queued observations may still be unread, and the coordinator refuses to start a copy for a reserved session whenever it reads them.

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

Asks an in-flight recovery copy for this session to stop. A foreground lifecycle operation calls this after reserving so it preempts the copy instead of waiting behind it.

Trait Implementations

impl Clone for RecoveryObserver

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.