Struct PeerLoadBalancer 

pub struct PeerLoadBalancer {
    pub peers: HashMap<String, PeerLoad>,
    pub strategy: LbStrategy,
    pub total_requests: u64,
}

Distributes requests across peers using a configurable LbStrategy.

Fields

peers: HashMap<String, PeerLoad>

All registered peers, keyed by peer id.

strategy: LbStrategy

Active load-balancing strategy.

total_requests: u64

Monotonically increasing counter; drives round-robin index and weighted-random index. Incremented on every successful select().

Implementations

impl PeerLoadBalancer

pub fn new(strategy: LbStrategy) -> Self

Creates a new, empty load balancer using strategy.

pub fn add_peer(&mut self, peer_id: &str, weight: u32)

Registers a peer. If the peer already exists its weight is updated.

pub fn remove_peer(&mut self, peer_id: &str) -> bool

Removes a peer. Returns true when the peer existed.

pub fn select(&mut self) -> Option<String>

Selects a peer according to the configured strategy.

Only healthy peers are considered. Returns None when no healthy peers are available. On success the internal request counter is incremented.

pub fn record_start(&mut self, peer_id: &str) -> bool

Marks the start of a request to peer_id.

Increments active_connections and total_requests on the peer. Returns false when the peer is not registered.

pub fn record_complete( &mut self, peer_id: &str, latency_ms: f64, success: bool, ) -> bool

Records the completion of a request to peer_id.

• Decrements active_connections (saturating at 0).
• Updates avg_latency_ms with EWMA alpha = 0.2.
• Increments failed_requests when success is false.

Returns false when the peer is not registered.

pub fn stats(&self) -> LbStats

Returns a snapshot of current load-balancer statistics.