Struct TickState 

pub struct TickState {
    pub examined: u32,
    pub committed: u32,
    pub attempted: u32,
    /* private fields */
}

Physical-tick counters. Fetching a page reserves its rows before processing them, so an exhausted scan allowance does not discard an already read page.

Fields

examined: u32

Rows fetched, including unknown, deferred and lookahead rows.

committed: u32

Successfully committed timer batches.

attempted: u32

Claimed handler invocations, including failures and races.

Implementations

impl TickState

pub fn new(clock: &dyn Clock, budget: TickBudget) -> Self

Begin one physical tick. Reuse this state for all its logical partitions.

pub fn remaining_scanned(&self) -> u32

Rows that another page may fetch.

pub fn exhausted(&self, clock: &dyn Clock) -> bool

Whether another page or partition must wait for a later physical tick.

pub fn work_exhausted(&self, clock: &dyn Clock) -> bool

Whether processing must stop, including inside an already reserved page. The scan allowance is excluded because those rows were charged on fetch.

pub fn charge_scan(&mut self, rows: u32) -> bool

Reserve exactly the number of fetched rows. An oversized charge changes no counters; the caller must limit its query to the remaining allowance.

pub fn claim_attempt( &mut self, kind: TimerKind, handler_cap: Option<u32>, ) -> bool

Claim one handler invocation before it runs. A handler can lower its kind’s allowance, but cannot enlarge the shared physical-tick ceiling.

pub fn committed(&mut self)

Record one successful guarded commit.

pub fn attempted_for(&self, kind: TimerKind) -> u32

Invocations already claimed by this kind, for verification and reporting.

Trait Implementations

impl Debug for TickState

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

Formats the value using the given formatter.