Struct AppliedIndexWatcher 

pub struct AppliedIndexWatcher { /* private fields */ }

Tracks the highest Raft log index applied on this node for one Raft group.

Implementations

impl AppliedIndexWatcher

pub fn new() -> Self

pub fn bump(&self, applied_index: u64)

Advance the watermark. Idempotent: smaller indices are ignored. Bumps on a closed watcher are also ignored (the group is gone).

pub fn current(&self) -> u64

Read the current watermark without blocking.

pub fn is_closed(&self) -> bool

True once Self::close has been called.

pub fn close(&self)

Mark this watcher closed and wake every waiter with WaitOutcome::GroupGone. Idempotent.

pub fn wait_for(&self, target: u64, timeout: Duration) -> WaitOutcome

Block until the watermark reaches target, the timeout elapses, or the watcher is closed.

Trait Implementations

impl Debug for AppliedIndexWatcher

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

Formats the value using the given formatter.

impl Default for AppliedIndexWatcher

fn default() -> AppliedIndexWatcher

Returns the “default value” for a type.