Struct ReadConsistencyConfig 

pub struct ReadConsistencyConfig {
    pub default_policy: ReadConsistencyPolicy,
    pub lease_duration_ms: u64,
    pub allow_client_override: bool,
    pub state_machine_sync_timeout_ms: u64,
    pub read_batching: ReadBatchingConfig,
}

Configuration for read operation consistency behavior

Fields

default_policy: ReadConsistencyPolicy

Default read consistency policy for the cluster

This sets the cluster-wide default behavior. Individual read requests can still override this setting when needed for specific use cases.

lease_duration_ms: u64

Lease duration in milliseconds for LeaseRead policy

Only applicable when using the LeaseRead policy. The leader considers itself valid for this duration after successfully heartbeating to a quorum.

allow_client_override: bool

Whether to allow clients to override the default policy per request

When true, clients can specify consistency requirements per read request. When false, all reads use the cluster’s default_policy setting.

state_machine_sync_timeout_ms: u64

Timeout in milliseconds to wait for state machine to catch up with commit index

Used by LinearizableRead to ensure the state machine has applied all committed entries before serving reads. Typical apply latency is <1ms on local SSD. Default: 10ms (safe buffer for single-node local deployments)

read_batching: ReadBatchingConfig

ReadIndex batching configuration

Trait Implementations

impl Clone for ReadConsistencyConfig

fn clone(&self) -> ReadConsistencyConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReadConsistencyConfig

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

Formats the value using the given formatter.

impl Default for ReadConsistencyConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ReadConsistencyConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ReadConsistencyConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.