Struct LagConfig 

pub struct LagConfig {
    pub replica_timeout_ms: u128,
    pub records_per_ms: Option<f64>,
    pub now_unix_ms: u128,
}

Knobs for the lag/health computation. Kept as a small struct so the call sites (gRPC topology RPC, RedWire HelloAck builder) thread the same defaults without each one redeclaring constants.

Fields

replica_timeout_ms: u128

Replica heartbeats older than this flip healthy to false.

records_per_ms: Option<f64>

Recent-progress estimate: how many WAL records the cluster applies per millisecond on average. None → lag conversion degrades gracefully to u32::MAX (issue spec: “if not estimable”).

now_unix_ms: u128

now in unix milliseconds. Threaded explicitly so tests can pin a deterministic clock without reaching for a global.

Implementations

impl LagConfig

pub fn from_now() -> LagConfig

Sensible default for production callers — replica_timeout at the module default, no progress estimate (so lag reports u32::MAX), now from the system clock.

Trait Implementations

impl Clone for LagConfig

fn clone(&self) -> LagConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LagConfig

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

Formats the value using the given formatter.

impl Copy for LagConfig