Struct ProxyPool 

pub struct ProxyPool { /* private fields */ }

An advanced proxy pool that measures latency, removes dead proxies, and sorts proxies by response time in ascending order.

Implementations

impl ProxyPool

pub fn new<T: IntoIterator<Item = impl AsRef<str>>>(url: T) -> Self

Create a new LatencyProxyPool from a list of proxy URLs.

pub fn code_range(self, code_range: Range<u16>) -> Self

Set the range of HTTP status codes that are considered successful.

pub fn test_url(self, test_url: String) -> Self

Set the URL used for testing proxy connectivity.

pub fn timeout(self, timeout: Duration) -> Self

Set the request timeout for proxy testing.

pub fn proxy(self, proxy: Proxy) -> Self

Set an optional upstream proxy for proxy validation.

pub fn max_check_concurrency(self, max_check_concurrency: usize) -> Self

Set the maximum number of concurrent proxy checks during health validation.

pub async fn available_count(&self) -> usize

Get the number of currently available (healthy) proxies.

pub async fn available(&self) -> Vec<String>

Get available proxies.

pub async fn extend<T: IntoIterator<Item = impl AsRef<str>>>(&self, urls: T)

Add new proxies to the pool without performing immediate validation.

New entries are appended, the cursor is reset, and the available count is updated. Validation occurs on the next check() call.

pub async fn extend_check<T: IntoIterator<Item = impl AsRef<str>>>( &self, url: T, retry_count: usize, ) -> Result<()>

Add new proxies and immediately perform connectivity and latency checks.

Proxies are validated, failed ones are removed, and remaining entries are sorted by latency (ascending).

pub async fn check(&self, retry_count: usize) -> Result<()>

Validate all proxies, remove dead ones, and sort by latency.

pub async fn spawn_check( &self, check_interval: Duration, retry_count: usize, ) -> Result<JoinHandle<()>>

Spawn a background task to periodically validate proxies and update order by latency.

Returns a JoinHandle to allow cancellation or awaiting of the task.

pub async fn spawn_check_callback<F, R>( &self, check_interval: Duration, retry_count: usize, callback: F, ) -> Result<JoinHandle<Result<()>>>

where F: Fn() -> R + Send + 'static, R: Future<Output = Result<()>> + Send,

Spawn a background task with a callback after each check.

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

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

Update the load balancer using a custom async handler.

Trait Implementations

impl BoxLoadBalancer<String> for ProxyPool

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

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

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

impl Clone for ProxyPool

fn clone(&self) -> ProxyPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl LoadBalancer<String> for ProxyPool

async fn alloc(&self) -> String

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