Struct QuorumConfig 

pub struct QuorumConfig {
    pub mode: QuorumMode,
    pub timeout: Option<Duration>,
}

Quorum configuration stored alongside ReplicationConfig.

Fields

mode: QuorumMode

timeout: Option<Duration>

How long the coordinator waits for acks before giving up. None = wait forever (use for strong consistency only when you can tolerate the writer stalling on a partitioned region).

Implementations

impl QuorumConfig

pub fn async_commit() -> Self

Ack immediately. Loss tolerance = 0 under primary failure.

pub fn sync(min_replicas: usize) -> Self

Wait for n replicas to ack (any region). Typical PG-like “synchronous_commit = on, synchronous_standby_names = ‘ANY n’”.

pub fn regions<I, S>(regions: I) -> Self

where I: IntoIterator<Item = S>, S: Into<String>,

Wait for at least one replica from each region in the set. Use this for disaster-recovery deployments across cloud regions.

pub fn with_timeout(self, timeout: Duration) -> Self

pub fn without_timeout(self) -> Self

pub fn is_async(&self) -> bool

Is this config ack-first (no wait)?

Trait Implementations

impl Clone for QuorumConfig

fn clone(&self) -> QuorumConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QuorumConfig

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

Formats the value using the given formatter.

impl Default for QuorumConfig

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq for QuorumConfig

fn eq(&self, other: &QuorumConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for QuorumConfig

impl StructuralPartialEq for QuorumConfig