Struct BookRecoveryState 

pub struct BookRecoveryState<E> { /* private fields */ }

Owns a book’s recovery episode under its adapter’s state lock.

Implementations

impl<E: Clone> BookRecoveryState<E>

pub fn claim(&mut self) -> Option<Arc<BookRecovery<E>>>

Claims one recovery episode, refusing while another is running.

pub fn current(&self) -> Option<&Arc<BookRecovery<E>>>

Returns the current episode.

pub fn is_running(&self) -> bool

Returns whether a running episode owns the book.

pub fn reset_on_reconnect(&mut self)

Keeps a running episode, whose replacement may be in flight, and cancels any other so the next claim starts fresh.

The kept episode keeps its budget. The reconnect never interrupts an attempt or shortens a backoff inside the budget. An episode waiting between attempts after its budget attempts again at once; a reconnect during an attempt or before the budget runs out ends the next such wait instead.

pub fn reset(&mut self)

Cancels the current episode.

Trait Implementations

impl<E: Debug> Debug for BookRecoveryState<E>

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

Formats the value using the given formatter.

impl<E> Default for BookRecoveryState<E>

fn default() -> Self

Returns the “default value” for a type.

impl<E> Drop for BookRecoveryState<E>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.