Struct LoadBalancer 

pub struct LoadBalancer { /* private fields */ }

Load balancer for distributing traffic across cluster nodes [AIR-3][AIS-3][PFM-3][SCL-3][RES-3]

Implementations

impl LoadBalancer

pub fn new(config: &HighAvailabilityConfig) -> Self

Creates a new load balancer with the specified configuration

pub async fn initialize(&mut self) -> Result<(), HaError>

Initializes the load balancer

pub async fn start(&mut self) -> Result<(), HaError>

Starts the load balancer

pub async fn stop(&mut self) -> Result<(), HaError>

Stops the load balancer

pub async fn select_node( &self, session_id: Option<&str>, ) -> Result<LoadBalancingResult, HaError>

Selects the best node for a request

pub async fn add_node(&self, node: LoadBalancerNode) -> Result<(), HaError>

Adds a node to the load balancer

pub async fn remove_node(&self, node_id: &str) -> Result<(), HaError>

Removes a node from the load balancer

pub async fn update_node_health( &self, node_id: &str, health_status: HealthState, ) -> Result<(), HaError>

Updates node health status

pub async fn record_request_completion( &self, node_id: &str, response_time: Duration, success: bool, ) -> Result<(), HaError>

Records request completion for a node

pub async fn update_config( &mut self, config: &HighAvailabilityConfig, ) -> Result<(), HaError>

Updates the load balancer configuration

pub async fn get_metrics(&self) -> LoadBalancerMetrics

Gets current load balancer metrics

pub async fn get_nodes(&self) -> HashMap<String, LoadBalancerNode>

Gets current node information

pub async fn is_enabled(&self) -> bool

Checks if the load balancer is enabled