Struct LoadBalancer 

pub struct LoadBalancer { /* private fields */ }

负载均衡器

Implementations

impl LoadBalancer

pub fn new<S>(backends: Backends, selector: S) -> Self

where S: Selector + Send + Sync + 'static, S::Iter: Send + Sync + 'static,

创建负载均衡器实例

pub fn with_health_check( self, health_check: impl HealthCheck + Send + Sync + 'static, ) -> Self

设置健康检查

pub fn with_update_frequency(self, update_frequency: Duration) -> Self

设置更新频率

pub fn with_health_check_frequency( self, health_check_frequency: Duration, ) -> Self

设置健康检查的频率

pub fn with_health_check_parallel(self, health_check_parallel: bool) -> Self

pub async fn update(&self) -> Result<(), Error>

运行服务发现并更新选择算法。

如果这个 LoadBalancer 实例作为后台服务运行，此函数将每隔 update_frequency 被调用一次。

pub fn select(&self, key: &[u8]) -> Option<Backend>

根据选择算法和健康检查结果返回第一个健康的 Backend。

key 用于基于哈希的选择，如果选择是随机或轮询，则忽略此参数。

max_iterations 用于限制搜索下一个 Backend 的时间。在某些算法中， 如 Ketama 哈希，搜索下一个后端是线性的，可能需要很多步骤。

pub fn select_with<F>(&self, key: &[u8], accept: F) -> Option<Backend>

where F: Fn(&Backend, bool) -> bool,

类似于 Self::select，根据选择算法和用户定义的 accept 函数返回第一个健康的 Backend。

accept 函数接受两个输入：正在选择的后端和该后端的内部健康状态。该函数可以执行一些操作， 比如忽略内部健康检查或因为之前失败而跳过这个后端。accept 函数会被多次调用，遍历后端， 直到返回 true。

Trait Implementations

impl BackgroundTask for LoadBalancer

fn run<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

执行任务