Struct BundlePullerBuilder 

pub struct BundlePullerBuilder { /* private fields */ }

Builds a BundlePuller (BundlePuller::builder).

Implementations

impl BundlePullerBuilder

pub fn relays(self, relays: Vec<RelayUrl>) -> Self

The relays to hint when dialing a node. The first one rides each dial.

pub const fn namespace(self, namespace: Option<u64>) -> Self

The namespace (ADR 002) every request carries: a node routes a cache miss to that namespace’s origins. None is the best-effort default.

pub const fn jobs(self, jobs: usize) -> Self

How many blobs fetch at once (at least 1; 4 by default).

pub const fn max_lane_streams(self, n: usize) -> Self

How many streams one provider’s lane runs at once across the whole pull (at least 1; 4 by default).

pub const fn max_rate_per_mb(self, rate: u64) -> Self

The highest per-MB rate a lane accepts; 0, the default, sets no ceiling.

pub const fn max_blob_bytes(self, bytes: u64) -> Self

The largest blob one entry fetches (1 TiB by default).

pub const fn stop( self, interactive: bool, give_up_after: Option<Duration>, ) -> Self

When the pull gives up after making no progress (crate::StopPolicy): an interactive pull waits for its caller to cancel, and any other stops after 10 minutes. give_up_after overrides both. Non-interactive by default.

pub fn observer(self, observer: Arc<dyn BundleObserver>) -> Self

Where the pull reports its progress. None by default.

pub fn unconfirmed_escrows(self, escrows: UnconfirmedEscrows) -> Self

Where the pull holds each openPool and topUp that no local record credits yet (UnconfirmedEscrows::pending), across every pass. A cancel or a fault that ends the pull can drop a receipt wait, and the transaction may still escrow. A pull that is not interrupted ends BundleEnd::Stopped on each one, and the caller keeps a clone to name what is left on BundleEnd::Interrupted. A topUp the handle holds also refuses every later topUp of the pull, across passes. The handle also holds each openPool and topUp that escrowed with no local record crediting it (UnconfirmedEscrows::untracked). It refuses every later openPool and topUp, ends every later pull on the handle BundleEnd::Stopped, and is the caller’s to name on BundleEnd::Interrupted. A private handle by default (BundlePuller::unconfirmed_escrows).

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

Build the puller: connect to the RPC endpoint and read the pool’s settlement token.

Errors

The RPC URL is malformed, the capability does not decode, the buyer store cannot read or record its lane salt (a self-owned run), or the PaymentPool token read fails.

Trait Implementations

impl Debug for BundlePullerBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.