Struct ConsistencyManager 

pub struct ConsistencyManager { /* private fields */ }

Enforces per-session monotonic-read and monotonic-write guarantees.

Sessions are identified by arbitrary string tokens (e.g., client IDs).

Implementations

impl ConsistencyManager

pub fn new(config: ConsistencyConfig) -> Self

Create a new manager with the given configuration.

pub fn can_read<T>( &mut self, session_id: &str, value: &VersionedValue<T>, ) -> bool

Determine whether a read of value is acceptable for session_id.

• Eventual / ReadYourWrites / Strong / Linearizable: always true
• MonotonicRead: value.version >= session's last-seen version

pub fn after_read<T>(&mut self, session_id: &str, value: &VersionedValue<T>)

Record that session_id has observed value (update monotonic-read floor).

pub fn can_write<T>( &mut self, session_id: &str, value: &VersionedValue<T>, ) -> bool

Determine whether a write of value is valid for session_id.

• MonotonicWrite: value.version >= session's last-write version
• everything else: always true

pub fn after_write<T>(&mut self, session_id: &str, value: &VersionedValue<T>)

Record that session_id performed a write at value’s version.

pub fn is_stale<T>( &self, value: &VersionedValue<T>, current_version: u64, ) -> bool

Return true if value.version is strictly behind current_version (i.e., the value is stale).

pub fn config(&self) -> &ConsistencyConfig

Reference to the active configuration.

pub fn monotonic_read_session_count(&self) -> usize

How many sessions are tracked for monotonic-read.

pub fn monotonic_write_session_count(&self) -> usize

How many sessions are tracked for monotonic-write.