Struct LagMonitor 

pub struct LagMonitor { /* private fields */ }

Lag Monitor - tracks replication lag across all nodes

Implementations

impl LagMonitor

pub fn new(config: LagRoutingConfig) -> Self

Create a new lag monitor

pub fn with_defaults() -> Self

Create with default config

pub fn is_running(&self) -> bool

Check if monitoring is running

pub fn start(&self)

Start monitoring (sets running flag)

pub fn stop(&self)

Stop monitoring

pub fn set_primary(&self, node_id: &str)

Set the primary node ID

pub fn get_primary(&self) -> Option<NodeId>

Get the primary node ID

pub fn update_primary_lsn(&self, lsn: u64)

Update primary LSN

pub fn get_primary_lsn(&self) -> u64

Get current primary LSN

pub fn register_standby(&self, node_id: &str, sync_mode: SyncMode)

Register a standby node

pub fn remove_node(&self, node_id: &str)

Remove a node from monitoring

pub fn update_standby_lag( &self, node_id: &str, current_lsn: u64, time_lag: Option<Duration>, )

Update lag info for a standby node

pub fn get_lag(&self, node_id: &str) -> Option<LagInfo>

Get lag info for a specific node

pub fn get_all_lags(&self) -> Vec<(NodeId, LagInfo)>

Get all current lag info

pub fn get_fresh_nodes(&self, max_lag: Duration) -> Vec<NodeId>

Get nodes that meet freshness requirement

pub fn get_nodes_at_lsn(&self, required_lsn: u64) -> Vec<NodeId>

Get nodes that have reached a specific LSN

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

Check if a node has reached a specific LSN

pub fn get_healthy_nodes(&self) -> Vec<NodeId>

Get healthy nodes (lag below stale threshold)

pub fn get_nodes_by_sync_mode(&self, mode: SyncMode) -> Vec<NodeId>

Get nodes by sync mode

pub fn get_freshest_standby(&self) -> Option<(NodeId, LagInfo)>

Get the freshest standby (lowest lag)

pub fn node_count(&self) -> usize

Get node count

pub fn clear(&self)

Clear all lag data

impl LagMonitor

pub fn arc(config: LagRoutingConfig) -> Arc<Self>

Create an Arc-wrapped instance

Trait Implementations

impl Debug for LagMonitor

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

Formats the value using the given formatter.