Struct TxAgeSweepState 

pub struct TxAgeSweepState { /* private fields */ }

ADR-091 Plank 1 background-sweep state, carried across ticks by the caller alongside CheckpointSeverityState and TruncateState. Pure state machine: no I/O, no logging — callers turn the returned emissions into tracing calls, mirroring CheckpointSeverityState’s shape.

Keyed off khive_storage::tx_registry::oldest() — the single oldest entry across every registered span, regardless of which call site created it. Deliberately a different signal from the WAL-pressure ladder: a span can go stale under low WAL pressure, or vice versa. See crates/khive-db/docs/api/checkpoint.md for the full rationale.

Implementations

impl TxAgeSweepState

pub fn observe( &mut self, oldest: Option<(TxId, Duration, Option<String>)>, config: &CheckpointConfig, ) -> Vec<TxAgeEmission>

Advance by one observed tick given the registry’s current oldest entry (identity, age, label), or None if empty. Returns zero, one, or two emissions — an entry already stale the first time it’s seen under a given identity crosses both rungs on the same tick.

A below-threshold (or absent) oldest entry resets both latches. A change in the oldest entry’s TxId also force-resets both latches before re-evaluating age, so a departed span’s latched state cannot suppress the crossing for an already-stale successor. See crates/khive-db/docs/api/checkpoint.md for why identity tracking is required here, not just the age check.

Trait Implementations

impl Clone for TxAgeSweepState

fn clone(&self) -> TxAgeSweepState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TxAgeSweepState

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

Formats the value using the given formatter.

impl Default for TxAgeSweepState

fn default() -> TxAgeSweepState

Returns the “default value” for a type.