Struct ProxyPool 

pub struct ProxyPool {
    pub config: PoolConfig,
    pub pools: Arc<RwLock<HashMap<String, Vec<ProxyItem>>>>,
    pub ip_providers: Arc<Mutex<HashMap<String, Arc<Box<dyn IpProxyLoader>>>>>,
    pub stats: Arc<RwLock<PoolStats>>,
}

Fields

config: PoolConfig

pools: Arc<RwLock<HashMap<String, Vec<ProxyItem>>>>

ip_providers: Arc<Mutex<HashMap<String, Arc<Box<dyn IpProxyLoader>>>>>

stats: Arc<RwLock<PoolStats>>

Implementations

impl ProxyPool

pub fn new(config: PoolConfig) -> Self

pub async fn add_tunnel(&self, tunnel: Tunnel)

pub async fn add_ip_provider(&self, provider: Box<dyn IpProxyLoader>)

pub async fn add_static_ip_proxy(&self, item: ProxyItem)

pub async fn get_proxy(&self, provider_name: Option<&str>) -> Result<ProxyEnum>

获取代理，支持负载均衡和故障转移

pub async fn get_best_tunnel(&self) -> Option<ProxyEnum>

获取质量最好的隧道代理

pub async fn report_proxy_result( &self, proxy: &ProxyEnum, success: bool, response_time: Option<Duration>, ) -> Result<()>

报告代理使用结果

pub async fn report_success( &self, proxy: &ProxyEnum, response_time: Option<Duration>, ) -> Result<()>

报告代理成功使用

pub async fn report_failure(&self, proxy: &ProxyEnum) -> Result<()>

报告代理失败使用

pub async fn get_pool_status(&self) -> HashMap<String, usize>

获取池状态

pub async fn get_stats(&self) -> PoolStats

获取详细统计信息

pub async fn health_check(&self) -> Result<()>

执行健康检查