Struct LagRoutingToml 

pub struct LagRoutingToml {
    pub enabled: bool,
    pub ryw_window_ms: u64,
    pub max_lag_bytes: u64,
}

Replica-lag-aware routing + read-your-writes configuration (always present; only enforced when the lag-routing feature is compiled in AND enabled).

Fields

enabled: bool

Enable lag-aware read routing + read-your-writes. Default false.

ryw_window_ms: u64

Reads issued within this many milliseconds after a write in the same session are pinned to the primary (read-your-writes), so the client observes its own writes despite replica lag. 0 disables the window.

max_lag_bytes: u64

Exclude a standby from read routing when its measured replication lag exceeds this many bytes. 0 = no lag-based exclusion (default; the proxy does not yet populate per-node lag without a configured monitor).

Trait Implementations

impl Clone for LagRoutingToml

fn clone(&self) -> LagRoutingToml

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LagRoutingToml

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

Formats the value using the given formatter.

impl Default for LagRoutingToml

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for LagRoutingToml

where LagRoutingToml: Default,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for LagRoutingToml

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

where __S: Serializer,

Serialize this value into the given Serde serializer.