Struct ClosedTimestampTracker 

pub struct ClosedTimestampTracker { /* private fields */ }

Tracks the most recent apply instant per Raft group.

Implementations

impl ClosedTimestampTracker

pub fn new() -> Self

pub fn mark_applied(&self, group_id: u64)

Record that group_id just applied one or more entries. Called by the raft-loop applier after each apply batch.

pub fn mark_applied_at(&self, group_id: u64, at: Instant)

Record that group_id just applied, using a caller-supplied instant. Exposed for deterministic testing with paused time.

pub fn is_fresh_enough(&self, group_id: u64, max_staleness: Duration) -> bool

Check whether this node’s replica of group_id has applied recently enough that a read with max_staleness can be served locally.

Returns false if the group has never applied on this node (no closed timestamp recorded).

pub fn staleness(&self, group_id: u64) -> Option<Duration>

Return the age of the closed timestamp for a group, or None if the group has never applied on this node. Useful for observability (metrics, SHOW commands).

Trait Implementations

impl Default for ClosedTimestampTracker

fn default() -> Self

Returns the “default value” for a type.