Struct ReplicationLagMonitor 

pub struct ReplicationLagMonitor { /* private fields */ }

复制延迟监控器

维护每个 slave 的最新延迟快照，提供基于延迟的路由决策。

Implementations

impl ReplicationLagMonitor

pub fn new(threshold_secs: u64) -> Self

创建监控器

pub fn with_max_history(self, max: usize) -> Self

设置最大历史保留条数

pub fn report(&self, slave: &str, lag_seconds: u64)

上报一次延迟采样

pub fn latest_lag(&self, slave: &str) -> Option<u64>

获取 slave 的最新延迟

pub fn is_lagging(&self, slave: &str) -> bool

判断 slave 是否延迟过大

pub fn is_safe_to_read(&self, slave: &str) -> bool

判断 slave 是否可以安全读取

pub fn lagging_slaves(&self) -> Vec<String>

返回所有延迟过大的 slave

pub fn safe_slaves(&self) -> Vec<String>

返回所有安全可读的 slave

pub fn history(&self, slave: &str) -> Vec<ReplicationLagSnapshot>

获取 slave 的延迟历史

pub fn avg_lag(&self, slave: &str) -> Option<u64>

计算 slave 的平均延迟（基于历史）

pub fn max_lag(&self, slave: &str) -> Option<u64>

计算 slave 的最大延迟（基于历史）

pub fn threshold(&self) -> u64

获取延迟阈值

pub fn reset(&self, slave: &str)

重置 slave 的历史

pub fn reset_all(&self)

重置所有 slave 的历史

pub fn select_least_lag<'a>(&self, candidates: &'a [String]) -> Option<&'a str>

从候选列表中选择延迟最小的 slave

返回 None 表示候选列表为空或无延迟数据。

pub fn min_lag(&self, slave: &str) -> Option<u64>

计算 slave 的最小延迟（基于历史）

pub fn all_slaves(&self) -> Vec<String>

返回所有已知 slave 列表

pub fn slave_count(&self) -> usize

已知 slave 数量

pub fn lag_trend(&self, slave: &str) -> i64

延迟趋势：比较最近两次采样

返回正数表示延迟上升，负数表示下降，0 表示稳定或数据不足。

pub fn summary(&self) -> String

生成汇总报告字符串