Struct ReplayGuard 

pub struct ReplayGuard {
    floor: u64,
    skipped: u64,
    first_skipped: u64,
    last_skipped: u64,
}

Skips messages at or below a trusted floor and counts them for logging.

Fields

floor: u64

skipped: u64

first_skipped: u64

last_skipped: u64

Implementations

impl ReplayGuard

pub fn new(floor: u64) -> Self

Creates a guard that skips stream sequences 1..=floor. A floor of 0 skips nothing.

pub fn floor(&self) -> u64

Current floor.

pub fn raise(&mut self, floor: u64)

Raises the floor; a lower value is ignored.

pub fn is_archived(&mut self, stream_seq: u64) -> bool

Returns true if the message at stream_seq is already archived and must be acked without writing. Sequence 0 (unknown) is never skipped.

pub fn skipped_in_run(&self) -> u64

Number of messages skipped in the current run.

pub fn take_run(&mut self) -> Option<SkipRun>

Ends the current run of skipped messages and returns it, if there was one.

Trait Implementations

impl Debug for ReplayGuard

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

Formats the value using the given formatter.

impl Default for ReplayGuard

fn default() -> ReplayGuard

Returns the “default value” for a type.