Struct LinearizableReader 

pub struct LinearizableReader { /* private fields */ }

A read accessor that goes through Raft consensus before returning a value.

Implementations

impl LinearizableReader

pub fn new( consensus: Arc<ConsensusManager>, state: Arc<RaftBackedOperatorState>, config: LinearizableReadConfig, ) -> Self

Build a reader.

pub async fn is_leader(&self) -> bool

Returns true if the local node currently believes itself the leader.

pub async fn term(&self) -> u64

Returns the latest known consensus term (for diagnostics).

pub async fn get(&self, key: &str) -> LinearizableReadResult<Option<StateValue>>

Leader-stickiness read of a key.

Cheap read path: checks that the local node is the leader, snapshots the current term, then serves from the local cache. The cache only reflects committed state, so this is monotonic when read from the leader. For strictly linearizable reads under contention, use Self::get_with_barrier.

pub async fn get_with_barrier( &self, key: &str, ) -> LinearizableReadResult<Option<StateValue>>

Strict linearizable read of a key.

Issues a BeginTransaction / RollbackTransaction pair through ConsensusManager::propose_command before reading the local cache. The pair is a Raft round-trip, so on return every commit issued before this call has been applied to the local replica.

Costs one Raft round-trip per call; use sparingly.

pub fn state(&self) -> &Arc<RaftBackedOperatorState>

Underlying operator state handle.

pub fn consensus(&self) -> &Arc<ConsensusManager>

Underlying consensus manager handle.