Struct LoadBalancer 

pub struct LoadBalancer { /* private fields */ }

Load Balancer

Implementations

impl LoadBalancer

pub fn new(config: LoadBalancerConfig) -> Self

Create a new load balancer

pub fn add_node(&mut self, endpoint: NodeEndpoint)

Add a node to the load balancer

pub fn remove_node(&mut self, node_id: &NodeId)

Remove a node from the load balancer

pub fn select_for_read(&self) -> Result<NodeEndpoint>

Select a node for a read query

pub fn select_for_write(&self) -> Result<NodeEndpoint>

Select a node for a write query

pub async fn set_node_health(&self, node_id: &NodeId, health: NodeHealth)

Set node health state

Supports granular health states for graceful degradation:

• Healthy: Normal operation
• Degraded: High latency/lag but still usable for reads
• Transitioning: Failover in progress
• Unhealthy: Do not route traffic

pub async fn set_node_healthy(&self, node_id: &NodeId, healthy: bool)

Legacy method for backward compatibility

pub async fn set_node_transitioning(&self, node_id: &NodeId)

Mark node as transitioning (failover in progress)

pub async fn update_latency(&self, node_id: &NodeId, latency_ms: f64)

Update node latency and adjust health state accordingly

pub async fn update_replication_lag(&self, node_id: &NodeId, lag_ms: u64)

Update node replication lag and adjust health state

pub async fn update_node_metrics( &self, node_id: &NodeId, latency_ms: f64, replication_lag_ms: u64, failure_rate: f64, )

Update node health based on combined metrics

pub async fn increment_connections(&self, node_id: &NodeId)

Increment connection count for a node

pub async fn decrement_connections(&self, node_id: &NodeId)

Decrement connection count for a node

pub async fn record_failure(&self, node_id: &NodeId)

Record a failure for a node

pub fn requests_routed(&self) -> u64

Get total requests routed

pub async fn node_stats(&self, node_id: &NodeId) -> Option<NodeStats>

Get node statistics

pub async fn all_stats(&self) -> HashMap<NodeId, NodeStats>

Get all node statistics