Struct NativeHttpClient

pub struct NativeHttpClient<D: NetworkDevice> {
    iface: NetInterface<D>,
    config: NativeClientConfig,
    socket: Option<SocketHandle>,
    get_time_ms: fn() -> u64,
}

Native bare-metal HTTP client.

Generic over NetworkDevice so it works with any driver:

• VirtIO (QEMU, KVM)
• Intel NICs (future)
• Realtek NICs (future)
• etc.

Fields

iface: NetInterface<D>

Network interface with TCP/IP stack.

config: NativeClientConfig

Client configuration.

socket: Option<SocketHandle>

Current TCP socket handle (if connected).

get_time_ms: fn() -> u64

Function to get current time in milliseconds. Must be provided by the caller (platform-specific).

Implementations

impl<D: NetworkDevice> NativeHttpClient<D>

pub fn new(device: D, net_config: NetConfig, get_time_ms: fn() -> u64) -> Self

Create a new native HTTP client.

Arguments

• device - Network device to use
• net_config - IP configuration (DHCP or static)
• get_time_ms - Function returning current time in milliseconds

pub fn with_config( device: D, net_config: NetConfig, client_config: NativeClientConfig, get_time_ms: fn() -> u64, ) -> Self

Create with custom configuration.

fn now(&self) -> u64

Get current timestamp.

pub fn poll(&mut self)

Poll the network interface.

pub fn is_network_ready(&self) -> bool

Check if network is ready (has IP address).

pub fn ip_address(&self) -> Option<Ipv4Addr>

Get current IP address.

pub fn wait_for_network(&mut self, timeout_ms: u64) -> Result<()>

Wait for network to be ready (DHCP complete or static configured).

pub fn resolve_host(&mut self, host: &str) -> Result<Ipv4Addr>

Resolve hostname to IP address using DNS or hardcoded fallbacks.

fn try_dns_query(&mut self, host: &str) -> Result<Ipv4Addr>

Attempt DNS resolution via UDP query.

fn lookup_hardcoded_dns(&self, host: &str) -> Result<Ipv4Addr>

Lookup host in hardcoded DNS table.

fn connect(&mut self, ip: Ipv4Addr, port: u16) -> Result<()>

Connect to a remote host.

fn close_existing_socket(&mut self)

Close any existing socket.

fn create_tcp_socket(&mut self) -> Result<SocketHandle>

Create a new TCP socket.

fn initiate_connection( &mut self, handle: SocketHandle, ip: Ipv4Addr, port: u16, ) -> Result<()>

Initiate TCP connection.

fn wait_for_connection(&mut self, handle: SocketHandle) -> Result<()>

Wait for TCP connection to complete.

fn send_all(&mut self, data: &[u8]) -> Result<()>

Send all data and wait for transmission to complete.

fn recv(&mut self, buffer: &mut [u8]) -> Result<usize>

Receive data with timeout.

fn read_headers(&mut self) -> Result<Vec<u8>>

Read HTTP headers until \r\n\r\n found.

fn read_full_response(&mut self) -> Result<Vec<u8>>

Read full HTTP response (headers + body).

fn read_remaining_body( &mut self, response_data: &mut Vec<u8>, body_start: usize, content_length: Option<usize>, ) -> Result<()>

Read remaining body data based on Content-Length.

fn stream_response_body<F>( &mut self, initial_body: &[u8], content_length: Option<usize>, callback: &mut F, ) -> Result<usize>

where F: FnMut(&[u8]) -> Result<()>,

Stream response body to callback.

fn do_request(&mut self, request: &Request) -> Result<Response>

Execute a basic HTTP request and return full response.

fn do_request_with_redirects(&mut self, request: Request) -> Result<Response>

Execute request with automatic redirect following.

fn build_redirect_request( &self, original: &Request, location: &str, ) -> Result<Request>

Build a new request for a redirect location.

pub fn get(&mut self, url: &str) -> Result<Response>

Simple GET request returning full response.

pub fn get_streaming<F>(&mut self, url: &str, callback: F) -> Result<usize>

where F: FnMut(&[u8]) -> Result<()>,

GET request with streaming callback for large downloads.

fn execute_streaming_request<F>( &mut self, url: &Url, callback: &mut F, ) -> Result<usize>

where F: FnMut(&[u8]) -> Result<()>,

Execute a streaming HTTP request.

fn stream_response<F>(&mut self, callback: &mut F) -> Result<usize>

where F: FnMut(&[u8]) -> Result<()>,

Stream the HTTP response to the callback.

pub fn close(&mut self)

Close any active connection.

pub fn interface(&self) -> &NetInterface<D>

Get reference to the network interface.

pub fn interface_mut(&mut self) -> &mut NetInterface<D>

Get mutable reference to the network interface.

Trait Implementations

impl<D: NetworkDevice> Drop for NativeHttpClient<D>

fn drop(&mut self)

Executes the destructor for this type.

impl<D: NetworkDevice> HttpClient for NativeHttpClient<D>

fn request(&mut self, request: &Request) -> Result<Response>

Execute an HTTP request.

fn request_with_progress( &mut self, request: &Request, _progress: ProgressCallback, ) -> Result<Response>

Execute request with progress tracking.

fn is_ready(&self) -> bool

Check if client is ready to make requests.