Struct GatewayPool 

pub struct GatewayPool { /* private fields */ }

Ordered pool of IPFS HTTP gateways with hedged failover and per-gateway Fibonacci cooldowns.

Read-only: fetches content and resolves IPNS paths. Publishing, pinning and key management belong to the Kubo client (crate::kubo), never here.

Implementations

impl GatewayPool

pub fn public_default() -> Self

Build a public-gateway pool with no localhost probing.

pub fn new(gateway_url: impl Into<String>) -> Self

Build a pool using the caller-provided primary gateway followed by the standard public fallbacks. Localhost is used only if gateway_url itself points at localhost.

pub fn local_first(gateway_url: impl Into<String>) -> Self

Build a local-first pool: localhost, then the caller-provided primary gateway, then the standard public fallbacks.

pub fn gateways(&self) -> &[String]

The ordered gateway URLs this pool will try.

pub fn with_base_cooldown(self, cooldown: Duration) -> Self

Override the base cooldown applied after a gateway failure. The cooldown escalates Fibonacci-style per consecutive failure and resets on success. Duration::ZERO disables cooldowns entirely.

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

Override the per-request timeout (default 6 seconds). The timeout covers the whole request, connection through body transfer, and is clamped to the time remaining before the operation deadline.

pub fn set_request_timeout(&self, timeout: Option<Duration>)

Update the per-request timeout at runtime. Pass None to revert to the 6-second built-in default.

pub async fn fetch<T>( &self, path: &str, accept: Option<&str>, parse: impl Fn(&[u8]) -> Result<T, String>, ) -> Result<T, String>

GET path from the gateway pool until parse accepts a body.

Gateways are tried in cooldown-filtered order, hedged: a pending attempt that has not answered within HEDGE_DELAY gets the next gateway raced against it and the first parsed success wins. Failing gateways earn an escalating Fibonacci cooldown; the whole operation is bounded by TOTAL_DEADLINE. On total failure the per-gateway errors are joined into one string for the caller to wrap.

pub async fn fetch_bytes( &self, path: &str, accept: Option<&str>, ) -> Result<Vec<u8>, String>

Fetch raw bytes for path (e.g. /ipfs/<cid>) with gateway failover.

pub async fn resolve_ipns_path(&self, path: &str) -> Result<String>

Resolve an /ipns/<name> reference to its current /ipfs/<cid> path.

Reads only gateway response metadata, never the referenced content body. Gateways commonly expose the resolved content path in X-Ipfs-Path; redirects to /ipfs/... are accepted as a fallback. Uses the same hedged failover and cooldowns as GatewayPool::fetch.

Trait Implementations

impl Default for GatewayPool

fn default() -> Self

Build a local-first pool for development and native runtimes.

impl From<GatewayPool> for IpfsGatewayResolver

fn from(pool: GatewayPool) -> Self

Converts to this type from the input type.