Struct PoolBuilder 

pub struct PoolBuilder { /* private fields */ }

Build a reusable pool. Clone the resulting pool to share rotation counters, health state, and per-node connection pools across tasks.

Implementations

impl PoolBuilder

pub fn new() -> Self

Start with per-request rotation, a 30s request timeout, and passive health feedback.

pub fn subscription(self, source: SubscriptionSource) -> Self

Add a subscription; repeated source URLs are deduplicated.

pub fn nodes(self, nodes: impl IntoIterator<Item = ProxyNode>) -> Self

Add static nodes, optionally alongside subscriptions.

pub fn cache(self, policy: CachePolicy) -> Self

Enable private, atomic on-disk subscription caching. Disabled by default.

pub fn rotation(self, policy: RotationPolicy) -> Self

Configure request-count and/or time-based rotation.

pub fn health(self, policy: HealthPolicy) -> Self

Configure health probes and failure cooldowns.

pub fn subscription_client(self, client: Client) -> Self

Override the subscription HTTP client, for example to use a bootstrap proxy. Its headers, redirects, and TLS policy are controlled by the caller.

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

Set the total timeout for each business request.

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

Set the connection timeout for each business client.

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

Bound the entire subscription download, including custom clients.

pub fn refresh_interval(self, interval: Duration) -> Self

Background remote refresh frequency, independent of the disk cache TTL.

pub fn health_interval(self, interval: Duration) -> Self

Background health check frequency.

pub fn max_subscription_bytes(self, bytes: usize) -> Self

Maximum response bytes accepted per subscription.

pub fn max_in_flight_per_proxy(self, limit: NonZeroUsize) -> Self

Bound business attempts per node. Saturated nodes are skipped; if all healthy nodes are busy, acquisition returns Error::PoolSaturated. Automatic execution releases its slot at response headers; a manual lease can be held until its response body has been consumed.

pub fn subscription_concurrency(self, limit: NonZeroUsize) -> Self

Bound simultaneous subscription requests, preserving source order.

pub async fn build(self) -> Result<ProxyPool>

Fetch or restore subscriptions, build clients, and optionally probe nodes. Returns an error for an empty pool or if initial checks find no healthy node.

Trait Implementations

impl Default for PoolBuilder

fn default() -> Self

Returns the “default value” for a type.