Struct LagInfo 

pub struct LagInfo {
    pub current_lsn: u64,
    pub lag_bytes: u64,
    pub lag_time: Duration,
    pub updated_at: Instant,
    pub trend: LagTrend,
    pub sync_mode: SyncMode,
    pub healthy: bool,
}

Lag information for a single node

Fields

current_lsn: u64

Current LSN (Log Sequence Number) on this node

lag_bytes: u64

Lag in bytes (LSN difference from primary)

lag_time: Duration

Estimated lag in time

updated_at: Instant

When this info was last updated

trend: LagTrend

Lag trend (improving, stable, degrading)

sync_mode: SyncMode

Node’s sync mode

healthy: bool

Whether the node is considered healthy based on lag

Implementations

impl LagInfo

pub fn is_stale(&self, max_age: Duration) -> bool

Check if this lag info is stale (not updated recently)

pub fn meets_freshness(&self, max_lag: Duration) -> bool

Check if this node meets the freshness requirement

pub fn has_reached_lsn(&self, required_lsn: u64) -> bool

Check if this node has reached a specific LSN

Trait Implementations

impl Clone for LagInfo

fn clone(&self) -> LagInfo

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LagInfo

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

Formats the value using the given formatter.

impl Default for LagInfo

fn default() -> Self

Returns the “default value” for a type.