Struct LoadBalancer 

pub struct LoadBalancer { /* private fields */ }

Load balancer for distributing requests across endpoints

Implementations

impl LoadBalancer

pub fn new(strategy: BalancingStrategy) -> Self

Create a new load balancer with the given strategy

pub fn add_endpoint(&self, endpoint: Endpoint)

Add an endpoint to the load balancer

pub fn remove_endpoint(&self, endpoint_id: &str) -> bool

Remove an endpoint from the load balancer

pub fn endpoints(&self) -> Vec<Arc<Endpoint>>

Get all endpoints

pub fn healthy_endpoints(&self) -> Vec<Arc<Endpoint>>

Get healthy endpoints

pub fn healthy_count(&self) -> usize

Get count of healthy endpoints

pub fn mark_unhealthy(&self, endpoint_index: usize)

Mark an endpoint as unhealthy by index

pub fn mark_healthy(&self, endpoint_index: usize)

Mark an endpoint as healthy by index

pub fn acquire(&self, endpoint_index: usize)

Acquire a connection to an endpoint (increments active count)

pub fn release(&self, endpoint_index: usize)

Release a connection to an endpoint (decrements active count)

pub fn select_endpoint(&self) -> NetResult<Arc<Endpoint>>

Select an endpoint using the configured strategy

pub fn select_for_key(&self, key: &[u8]) -> NetResult<Arc<Endpoint>>

Select an endpoint for a specific key (consistent hashing)

Maps the given key deterministically to an endpoint. Adding or removing endpoints only remaps approximately 1/N of keys.

pub fn select_with_affinity(&self, session_id: &str) -> NetResult<Arc<Endpoint>>

Select endpoint with affinity (sticky session)

pub fn clear_affinity(&self, session_id: &str)

Clear session affinity

pub fn stats(&self) -> BalancerStats

Get load balancing statistics

Trait Implementations

impl Debug for LoadBalancer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.