Struct HttpBackend 

pub struct HttpBackend { /* private fields */ }

HTTP storage backend with embedded Tokio runtime.

This backend wraps an async reqwest::Client and Tokio Runtime to provide synchronous StorageBackend operations while leveraging async I/O internally. It validates URLs for security, maintains a connection pool, and performs range requests to fetch specific byte ranges.

Examples

use hexz_core::store::http::HttpBackend;
use hexz_core::store::StorageBackend;

let backend = HttpBackend::new(
    "https://example.com/snapshot.hxz".to_string(),
    false
)?;

let data = backend.read_exact(8192, 4096)?;
assert_eq!(data.len(), 4096);

Implementations

impl HttpBackend

pub fn new(url: String, allow_restricted: bool) -> Result<Self>

Creates a new HTTP backend by validating the URL and fetching file metadata.

This constructor:

1. Validates the URL for security (blocks restricted IPs unless allowed)
2. Creates a Tokio runtime for executing async operations
3. Sends an async HEAD request to verify the server and fetch file size
4. Extracts the Content-Length header to determine snapshot size

Parameters

• url: The HTTP/HTTPS URL of the snapshot file
• allow_restricted: If false, blocks access to localhost and private networks

Trait Implementations

impl Debug for HttpBackend

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

Formats the value using the given formatter.

impl StorageBackend for HttpBackend

fn read_exact(&self, offset: u64, len: usize) -> Result<Bytes>

Reads exactly len bytes starting at offset from the underlying store.

fn len(&self) -> u64

Returns the total logical size of the underlying snapshot in bytes.

fn is_empty(&self) -> bool

Returns true if the underlying store has zero length.