Struct LagMonitor 

pub struct LagMonitor { /* private fields */ }

Monitor for tracking replication lag.

Implementations

impl LagMonitor

pub fn new(max_acceptable_lag: Duration) -> Self

Create a new lag monitor.

pub fn record(&mut self, replica_id: &str, lag: Duration)

Record a lag measurement.

pub fn is_acceptable(&self, replica_id: &str) -> bool

Check if a replica is within acceptable lag.

pub fn get_lag(&self, replica_id: &str) -> Option<Duration>

Get current lag for a replica.

pub fn get_lagging_replicas(&self) -> Vec<&str>

Get all replicas that are lagging too much.

Trait Implementations

impl Debug for LagMonitor

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

Formats the value using the given formatter.