Struct IPClientLoadBalancer 

pub struct IPClientLoadBalancer { /* private fields */ }

Load balancer for reqwest::Client instances bound to specific IP addresses. Supports limits per client and optional interval-based resets.

Implementations

impl IPClientLoadBalancer

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

Create a new load balancer with fixed clients and limits.

pub fn new_interval(entries: Vec<(u64, Client)>, interval: Duration) -> Self

Create a new load balancer with a custom interval for resetting limits.

pub fn with_ipv4(limit: u64) -> Self

Build a load balancer using all local IPv4 addresses.

pub fn with_ipv4_interval(limit: u64, interval: Duration) -> Self

Build a load balancer using IPv4 addresses with a custom interval.

pub fn with_ipv6(limit: u64) -> Self

Build a load balancer using all local IPv6 addresses.

pub fn with_ipv6_interval(limit: u64, interval: Duration) -> Self

Build a load balancer using IPv6 addresses with a custom interval.

pub fn with_ipv4_timeout(limit: u64, timeout: Duration) -> Self

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

pub fn with_ipv4_interval_timeout( limit: u64, interval: Duration, timeout: Duration, ) -> Self

Build a load balancer using IPv4 addresses with interval and timeout.

pub fn with_ipv6_timeout(limit: u64, timeout: Duration) -> Self

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

pub fn with_ipv6_interval_timeout( limit: u64, interval: Duration, timeout: Duration, ) -> Self

Build a load balancer using IPv6 addresses with interval and timeout.

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

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

Update the internal load balancer using a custom async closure.

Trait Implementations

impl BoxLoadBalancer<Client> for IPClientLoadBalancer

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

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

Allocate a client asynchronously.

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

Attempt to allocate a client immediately.

impl Clone for IPClientLoadBalancer

fn clone(&self) -> IPClientLoadBalancer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl LoadBalancer<Client> for IPClientLoadBalancer

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

Allocate a client asynchronously.

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

Attempt to allocate a client immediately.