Struct ScatterProxyRouter 

pub struct ScatterProxyRouter { /* private fields */ }

Routes proxied requests to per-host ScatterProxy instances.

Each registered host gets its own independent proxy pool, health tracker, and scheduler. Isolation means:

• A struggling host (all proxies in cooldown, low success rate) cannot starve tasks for other hosts.
• Proxy eviction is scoped per-host: a proxy that repeatedly fails for host A is marked dead only in A’s pool, while remaining available to B.
• metrics_for gives a clean, host-scoped view of throughput and health.

Each host is configured independently via its own ScatterProxyConfig, so you can tune sources, concurrency, timeouts, and logging per target.

Example

use scatter_proxy::{ScatterProxyRouter, ScatterProxyConfig, DefaultClassifier};

let router = ScatterProxyRouter::new(
    [
        ("szse.cn",     ScatterProxyConfig { max_inflight: 20, ..Default::default() }),
        ("sse.com.cn",  ScatterProxyConfig { max_inflight: 10, ..Default::default() }),
        ("cninfo.com.cn", ScatterProxyConfig::default()),
    ],
    DefaultClassifier,
).await?;

let client = reqwest::Client::new();
let req = client.get("http://szse.cn/api/data").build().unwrap();
let handle = router.submit(req).await?;
// handle.await or handle.with_timeout(…) as usual

// Per-host observability
if let Some(m) = router.metrics_for("szse.cn") {
    println!("szse success rate: {:.0}%", m.success_rate_1m * 100.0);
}

router.shutdown().await;

Implementations

impl ScatterProxyRouter

pub async fn new( routes: impl IntoIterator<Item = (impl Into<String>, ScatterProxyConfig)>, classifier: impl BodyClassifier, ) -> Result<Self, ScatterProxyError>

Build a router with one independent ScatterProxy pool per host.

routes is an iterable of (hostname, config) pairs. Each host gets its own pool configured independently. If config.name is not set it defaults to the hostname so that metrics logs are prefixed correctly.

Errors

Returns ScatterProxyError::Init if any host pool fails to initialise (e.g. the proxy source URL is unreachable and the list is empty).

pub async fn submit( &self, request: Request, ) -> Result<TaskHandle, ScatterProxyError>

Submit a request to the pool registered for its host.

Blocks until the pool has capacity, then returns a TaskHandle.

Errors

Returns ScatterProxyError::UnknownHost if the request’s host is not registered in this router.

pub fn try_submit( &self, request: Request, ) -> Result<TaskHandle, ScatterProxyError>

Non-blocking submit variant.

Errors

Returns ScatterProxyError::UnknownHost if the host is not registered, or ScatterProxyError::PoolFull if the host’s pool is at capacity.

pub fn metrics_for(&self, host: &str) -> Option<PoolMetrics>

Returns a PoolMetrics snapshot for the given host.

Returns None if the host is not registered in this router.

pub fn all_metrics(&self) -> HashMap<String, PoolMetrics>

Returns PoolMetrics snapshots for every registered host.

pub fn hosts(&self) -> Vec<&str>

Returns the list of registered hostnames.

pub async fn shutdown(self)

Gracefully shut down all host pools (persists state for each if configured).