Struct IPClient 

pub struct IPClient { /* private fields */ }

Load balancer for reqwest::Client instances bound to specific IP addresses. Uses interval-based allocation.

Implementations

impl IPClient

pub fn new(entries: Vec<(Duration, Client)>) -> Self

Create a new interval-based load balancer with given clients.

pub fn with_ip(ip: Vec<IpAddr>, interval: Duration) -> Self

Build a load balancer using all local IP addresses.

pub fn with_timeout( ip: Vec<IpAddr>, interval: Duration, timeout: Duration, ) -> Self

Build a load balancer using IP addresses with a per-client timeout.

pub fn with_timeout_proxy( ip: Vec<IpAddr>, interval: Duration, timeout: Duration, proxy: Proxy, ) -> Self

Build a load balancer using IP addresses with a per-client timeout, use proxy.

pub async fn update<F, R>(&self, handle: F) -> Result<()>

where F: Fn(Arc<RwLock<Vec<Entry<Client>>>>) -> R, R: Future<Output = Result<()>>,

Update the internal load balancer.

Trait Implementations

impl BoxLoadBalancer<Client> for IPClient

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

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

fn try_alloc(&self) -> Option<Client>

impl Clone for IPClient

fn clone(&self) -> IPClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl LoadBalancer<Client> for IPClient

fn alloc(&self) -> impl Future<Output = Client> + Send

fn try_alloc(&self) -> Option<Client>