Struct ReadWriteRouter 

pub struct ReadWriteRouter { /* private fields */ }

读写分离路由器

master 处理写请求，slave 集群处理读请求。 根据 LoadBalanceStrategy 在多个 slave 间分配读请求。

Implementations

impl ReadWriteRouter

pub fn new(master: &str, slaves: Vec<&str>) -> Self

pub fn master(&self) -> &str

返回 master 节点

pub fn slaves(&self) -> &[String]

返回 slave 列表

pub fn slave(&self) -> &str

根据当前策略选择一个 slave

如果 slaves 为空，回退到 master。 如果启用健康检查，会跳过 Unhealthy/Drained 的 slave。

pub fn set_strategy(&mut self, strategy: LoadBalanceStrategy)

设置负载均衡策略

pub fn strategy(&self) -> LoadBalanceStrategy

获取当前策略

pub fn set_weight(&self, slave: &str, weight: u32) -> Result<(), String>

设置 slave 权重

pub fn weight(&self, slave: &str) -> Option<u32>

获取 slave 权重

pub fn health_checker(&self) -> &HealthChecker

健康检查器引用

pub fn latency_stats(&self) -> &LatencyStats

延迟统计引用

pub fn record_latency(&self, slave: &str, latency: Duration)

记录一次 slave 请求的延迟

pub fn measure<F, T>(&self, slave: &str, f: F) -> T

where F: FnOnce() -> T,

测量并记录一次 slave 调用的耗时

pub fn set_read_rationing(&self, percent: u8)

配置读写比例

pub fn read_rationing_percent(&self) -> u8

获取当前读写比例

pub fn acquire(&self, slave: &str) -> Result<(), String>

在某个 slave 上获取连接（增加连接计数，用于 LeastConnections）

pub fn release(&self, slave: &str) -> Result<(), String>

释放某个 slave 的连接（减少连接计数）

pub fn connection_count(&self, slave: &str) -> Option<usize>

查询某个 slave 的当前连接数（用于测试和监控）