reqwest-lb 0.3.1

The reqwest load balancer middleware
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

use crate::lb::BoxLoadBalancer;
use crate::LoadBalancerTrait;
use std::collections::HashMap;
use std::convert::Infallible;

pub struct LoadBalancerRegistry<I, E = Infallible> {
    registry: HashMap<String, BoxLoadBalancer<I, E>>,
}

impl<I, E> Default for LoadBalancerRegistry<I, E> {
    fn default() -> Self {
        Self {
            registry: HashMap::default(),
        }
    }
}

impl<I, E> LoadBalancerRegistry<I, E> {
    pub fn add<L>(&mut self, host: &str, load_balancer: L)
    where
        L: LoadBalancerTrait<Element = I, Error = E> + Send + Sync + 'static,
        L::Future: Send + 'static,
    {
        self.registry
            .insert(host.to_string(), load_balancer.boxed());
    }

    pub fn remove(&mut self, host: &str) {
        self.registry.remove(host);
    }

    pub fn find(&self, host: &str) -> Option<&BoxLoadBalancer<I, E>> {
        self.registry.get(host)
    }
}