Struct HttpEngineLocal 

pub struct HttpEngineLocal<R, C> { /* private fields */ }

HTTP client for completion-based runtimes (compio).

Wraps HttpEngineCore with a !Send-capable connector.

Implementations

impl<R: RuntimeLocal, C: ConnectorLocal + Clone + Default> HttpEngineLocal<R, C>

pub fn new() -> Self

Create a new client with default settings for a completion-based runtime.

pub fn builder() -> HttpEngineBuilder<R, C>

Create a new HttpEngineBuilder for a completion-based runtime.

pub fn with_rustls() -> Self

Create a client with rustls TLS for a completion-based runtime.

impl<R: RuntimeLocal, C: ConnectorLocal + Clone> HttpEngineLocal<R, C>

pub fn builder_with_connector(connector: C) -> HttpEngineBuilder<R, C>

Create a new HttpEngineBuilder with a specific connector for a completion-based runtime.

pub fn with_connector(connector: C) -> Self

Create a new client with default settings and a specific connector.

pub fn with_rustls_connector(connector: C) -> Self

Create a client with rustls TLS and a specific connector for a completion-based runtime.

pub fn get_local( &self, uri: &str, ) -> Result<RequestBuilderLocal<'_, R, C>, Error>

Start a GET request to the given URL.

pub fn post_local( &self, uri: &str, ) -> Result<RequestBuilderLocal<'_, R, C>, Error>

Start a POST request to the given URL.

pub fn request_local( &self, method: Method, uri: &str, ) -> Result<RequestBuilderLocal<'_, R, C>, Error>

Start a request with the given method and URL.

pub fn chunk_download_local(&self, url: &str) -> ChunkDownloadLocal<R, C>

Start a parallel chunk download for the given URL.

pub async fn resolve_all( &self, host: &str, port: u16, ) -> Result<Vec<SocketAddr>, Error>

Resolve a hostname to all socket addresses using the configured DNS resolver.

Returns every address the resolver provides. This enables service discovery and custom load-balancing: resolve once, select an address with your strategy (round-robin, least-connections, consistent hashing), then send the request to the chosen address via crate::RequestBuilderLocal::force_addr.

For a host that is already an IP literal, this returns a single-element vec without consulting any resolver.

pub fn forward_local<B>( &self, request: Request<B>, ) -> ForwardBuilderLocal<'_, R, C, B>

where B: Body<Data = Bytes> + 'static, B::Error: Into<Box<dyn Error + Send + Sync>>,

Forward an incoming HTTP request to an upstream server.

impl<R, C> HttpEngineLocal<R, C>

pub fn pool_stats(&self) -> PoolStats

Take a snapshot of connection pool statistics.

Trait Implementations

impl<R, C: Clone> Clone for HttpEngineLocal<R, C>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<R, C> Debug for HttpEngineLocal<R, C>

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

Formats the value using the given formatter.

impl<R: RuntimeLocal, C: ConnectorLocal + Clone + Default> Default for HttpEngineLocal<R, C>

fn default() -> Self

Returns the “default value” for a type.

impl<R: RuntimeLocal, C: ConnectorLocal + Clone> HttpClient for HttpEngineLocal<R, C>

type RequestBuilder = OwnedRequestBuilderLocal<R, C>

The request builder type returned by request().

fn request( &self, method: Method, uri: &str, ) -> Result<Self::RequestBuilder, Error>

Start a request with the given HTTP method and URL.

fn get(&self, uri: &str) -> Result<Self::RequestBuilder, Error>

Start a GET request.

fn head(&self, uri: &str) -> Result<Self::RequestBuilder, Error>

Start a HEAD request.

fn post(&self, uri: &str) -> Result<Self::RequestBuilder, Error>

Start a POST request.

fn put(&self, uri: &str) -> Result<Self::RequestBuilder, Error>

Start a PUT request.

fn patch(&self, uri: &str) -> Result<Self::RequestBuilder, Error>

Start a PATCH request.

fn delete(&self, uri: &str) -> Result<Self::RequestBuilder, Error>

Start a DELETE request.