Struct BookRecovery 

pub struct BookRecovery<E> {
    pub cancellation: CancellationToken,
    pub outcome: Sender<BookRecoveryOutcome<E>>,
    pub gate: SnapshotGate,
}

One recovery episode, retained across reconnects until a snapshot or terminal failure.

Fields

cancellation: CancellationToken

outcome: Sender<BookRecoveryOutcome<E>>

gate: SnapshotGate

Implementations

impl<E: Clone> BookRecovery<E>

pub fn begin_replacement(&self) -> bool

Closes snapshot acceptance, returning false if this episode has already ended.

pub fn is_accepted(&self) -> bool

Returns whether the adapter has accepted a snapshot for this episode.

pub fn accept(&self) -> bool

Returns true when the gate permits accepting a snapshot for this episode.

impl<E: Clone + Error> BookRecovery<E>

pub async fn run<F, Fut>( &self, snapshot_timeout: Duration, replace: F, should_retry: impl Fn(&E) -> bool, create_error: impl Fn(String) -> E, timeout_error: impl Fn() -> E, ) -> Result<(), E>

where F: Fn(CancellationToken, SnapshotGate) -> Fut, Fut: Future<Output = Result<(), E>>,

Replaces the subscription and waits for a snapshot, with bounded retries.

Each send receives a child cancellation token. Dropping an attempt cancels queued transport work. Keeping this future alive across reconnects preserves the attempt limit and total elapsed-time budget. A zero snapshot timeout disables only the individual snapshot deadline.

Errors

Returns the terminal adapter error, cancellation, or exhausted retry budget.

Trait Implementations

impl<E: Debug> Debug for BookRecovery<E>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<E: Clone> Default for BookRecovery<E>

fn default() -> Self

Returns the “default value” for a type.