Common request analysis logic shared between streaming and non-streaming implementations

Collect a body into bytes.

Performs a conditional fetch (revalidation) against the origin, returning either the still-valid cached response or the fresh upstream response. Mirr

Create a DELETE request

Convert to bytes, consuming the response

Converts response parts to HttpResponse format for cache mode evaluation

Create a PUT request

Removes a warning header from a response

Returns `true` if the `cache-control` header of the response contains the `must-revalidate` directive.

Add a header to the request

Helper function to add cache status headers to a response

Clears all entries from the cache — moka, redb, and on-disk bodies.

Converts a reqwest Response to an http::Response with Full body for streaming cache processing

Converts an [`HttpResponse`] to a reqwest [`Response`]

Determine the appropriate scheme for URL construction

Universal function for JSON requests - eliminates method-specific duplication

Extract Vary headers from response parts.

Convert an [`HttpResponse`] from the cache core into a Tower `Response<HttpCacheBody<B>>`.

Convert this streaming body into a stream of Bytes. This method allows for streaming without collecting the entire body into memory first.

Check if this cached response is stale.

Get the error kind

Get a reference to the cache metrics.

Parse Expires header to calculate TTL. Returns the duration until expiration, or None if the date is invalid or in the past.

Parse max-age from Cache-Control header.

Parse s-maxage from Cache-Control header (shared cache specific).

Read a metadata row from redb by key.

Check if response explicitly permits caching of authorized requests per RFC 9111 §3.5. Returns true if the response contains directives that allow ca

Removes the warning header from an `http::Response`.

Extracts the warning code from an `http::Response`'s warning header, if present. Returns the 3-digit warn-code as a `usize`.

Delete every entry in `tmp_dir`. Called on startup after we hold the redb lock, so no concurrent put is in-flight.

Convert u8 back to HTTP version.

Convert HTTP version to u8 for compact storage.

Set the ureq agent configuration The provided configuration will be used to preserve your settings like timeout, proxy, TLS config, and user agent. H

Benchmark cache hit performance - buffered vs streaming

Benchmark cache miss performance - buffered vs streaming

Benchmark streaming cache throughput with concurrent requests

Build a `Response<StreamingBody>` from an opened body file and validated metadata. File cursor must already be past the 16-byte nonce header.

Create a new builder

Create a cache operation error # Examples ```rust use http_cache::HttpCacheError; let err = HttpCacheError::cache("Cache entry not found"); ```