Struct ReadWriteRouter 

pub struct ReadWriteRouter { /* private fields */ }

Read-write splitting router

Master handles write requests, slave cluster handles read requests. Distributes read requests across multiple slaves according to LoadBalanceStrategy.

Implementations

impl ReadWriteRouter

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

pub fn master(&self) -> &str

Return the master node

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

Return the slave list

pub fn slave(&self) -> &str

Select a slave according to the current strategy

If slaves is empty, falls back to master. If health check is enabled, skips Unhealthy/Drained slaves.

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

Set the load balancing strategy

pub fn strategy(&self) -> LoadBalanceStrategy

Get the current strategy

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

Set slave weight

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

Get slave weight

pub fn health_checker(&self) -> &HealthChecker

Health checker reference

pub fn latency_stats(&self) -> &LatencyStats

Latency statistics reference

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

Record the latency of a slave request

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

where F: FnOnce() -> T,

Measure and record the duration of a slave call

pub fn set_read_rationing(&self, percent: u8)

Configure the read-write ratio

pub fn read_rationing_percent(&self) -> u8

Get the current read-write ratio

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

Acquire a connection on a given slave (increment connection count, used for LeastConnections)

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

Release a connection on a given slave (decrement connection count)

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

Query the current connection count of a slave (for testing and monitoring)