Struct HttpClient 

pub struct HttpClient { /* private fields */ }

Production HTTP client used across the workspace. Wraps a raw reqwest::Client with the workspace’s [RetryNet] decorator so every Net method (head/get_bytes/get_range/stream) honours options.retry_policy — retryable errors (TLS-close, timeout, 5xx, IO) are re-issued with exponential backoff; non-retryable errors (HTTP 4xx, cancellation) propagate immediately.

Implementations

impl HttpClient

pub fn new(options: NetOptions, cancel: CancellationToken) -> Self

Build a retry-decorated HTTP client rooted on cancel. The RetryNet layer aborts pending retries when that token is cancelled. Callers MUST pass a token that lives in the consumer-crate’s cancel tree — typically master_cancel.child_token() derived at the consumer-crate top (App, Queue, FFI player). The workspace cancel hierarchy forbids orphan tokens in production code.

Panics

Panics if the reqwest::Client builder fails to build.

pub async fn get_bytes( &self, url: Url, headers: Option<Headers>, ) -> NetResult<Bytes>

Errors

Returns NetError on HTTP failure, timeout, or network error.

pub async fn get_range( &self, url: Url, range: RangeSpec, headers: Option<Headers>, ) -> NetResult<ByteStream>

Errors

Returns NetError on HTTP failure or network error.

pub async fn head( &self, url: Url, headers: Option<Headers>, ) -> NetResult<Headers>

Errors

Returns NetError on HTTP failure or network error.

pub fn options(&self) -> &NetOptions

pub async fn stream( &self, url: Url, headers: Option<Headers>, ) -> NetResult<ByteStream>

Errors

Returns NetError on HTTP failure or network error.

Trait Implementations

impl Clone for HttpClient

fn clone(&self) -> HttpClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for HttpClient

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

Formats the value using the given formatter.

impl Net for HttpClient

fn get_bytes<'life0, 'async_trait>( &'life0 self, url: Url, headers: Option<Headers>, ) -> Pin<Box<dyn Future<Output = Result<Bytes, NetError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get all bytes from a URL

fn get_range<'life0, 'async_trait>( &'life0 self, url: Url, range: RangeSpec, headers: Option<Headers>, ) -> Pin<Box<dyn Future<Output = Result<ByteStream, NetError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get a range of bytes from a URL

fn head<'life0, 'async_trait>( &'life0 self, url: Url, headers: Option<Headers>, ) -> Pin<Box<dyn Future<Output = Result<Headers, NetError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Perform a HEAD request.

fn stream<'life0, 'async_trait>( &'life0 self, url: Url, headers: Option<Headers>, ) -> Pin<Box<dyn Future<Output = Result<ByteStream, NetError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stream bytes from a URL