Struct ScatterProxy 

pub struct ScatterProxy { /* private fields */ }

The main entry point. Manages proxy pool, scheduling, and background tasks.

Implementations

impl ScatterProxy

pub async fn new( config: ScatterProxyConfig, classifier: impl BodyClassifier, ) -> Result<Self, ScatterProxyError>

Create a new ScatterProxy from config and a body classifier.

This is an async constructor that fetches proxies, restores persisted state, and spawns all background tasks (scheduler, persistence, metrics logging, source refresh).

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

Submit a single request for proxied execution.

Returns a TaskHandle that implements Future and resolves to the proxied response (or an error).

pub fn submit_batch( &self, requests: Vec<Request>, ) -> Result<Vec<TaskHandle>, ScatterProxyError>

Submit a batch of requests for proxied execution.

All requests are added atomically — if the pool doesn’t have enough capacity the entire batch is rejected.

pub fn metrics(&self) -> PoolMetrics

Build a PoolMetrics snapshot from all internal components.

pub async fn shutdown(self)

Gracefully shut down the proxy: signal all background tasks, persist final state, and drop resources.