Struct FencingTokenState 

pub struct FencingTokenState { /* private fields */ }

Volatile fencing-token state shared across the cluster node.

Stores the current packed fencing token as an AtomicU64 so that concurrent readers (e.g. storage guards) can check staleness without taking a lock. The high 32 bits encode the Raft term; the low 32 bits encode the monotonic write sequence within that term.

Implementations

impl FencingTokenState

pub fn new() -> Self

Create a new state with token = 0 (no leader epoch yet).

pub fn issue_token(&self) -> FencingToken

Atomically issue the next fencing token by incrementing the sequence.

Intended to be called on every write from the current leader.

pub fn bump_term_token(&self, new_term: u32)

Bump the token to a new leader term, resetting the sequence to zero.

This must be called atomically when a node wins an election.

pub fn current_raw(&self) -> u64

Read the current raw token value (for serialisation / inspection).

Trait Implementations

impl Debug for FencingTokenState

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

Formats the value using the given formatter.

impl Default for FencingTokenState

fn default() -> Self

Returns the “default value” for a type.