Struct LoadBalancer 

pub struct LoadBalancer {
    pub service: Arc<ServiceConfig>,
    pub states: Arc<Mutex<HashMap<String, LbState>>>,
}

简单的负载选择器，当前仅按权重随机，未来可扩展为按 usage / 失败次数等切换。

Fields

service: Arc<ServiceConfig>

states: Arc<Mutex<HashMap<String, LbState>>>

Implementations

impl LoadBalancer

pub fn new( service: Arc<ServiceConfig>, states: Arc<Mutex<HashMap<String, LbState>>>, ) -> LoadBalancer

pub fn select_upstream_avoiding( &self, avoid: &HashSet<usize>, ) -> Option<SelectedUpstream>

pub fn select_upstream_avoiding_strict( &self, avoid: &HashSet<usize>, ) -> Option<SelectedUpstream>

pub fn penalize_with_backoff( &self, index: usize, cooldown_secs: u64, reason: &str, backoff: CooldownBackoff, )

pub fn record_result_with_backoff( &self, index: usize, success: bool, failure_threshold_cooldown_secs: u64, backoff: CooldownBackoff, )

Trait Implementations

impl Clone for LoadBalancer

fn clone(&self) -> LoadBalancer

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.