Struct HttpClient 

pub struct HttpClient { /* private fields */ }

A Tower Service that sends HTTP requests to upstream services.

The transport is picked from the request URI: http:// and https:// go through TCP, unix:// through a Unix domain socket (Unix targets only). The HTTP version inside that transport is configured via HttpClientConfig.

HttpClient is cheap to clone — all clones share the same underlying connections and configuration.

Example

use apollo_http_client::{HttpClient, HttpClientConfig};
use http_body_util::Empty;
use bytes::Bytes;
use tower::ServiceExt;

let config = HttpClientConfig::default();
let client = HttpClient::new(&config).expect("valid config");

let req = http::Request::builder()
    .method("GET")
    .uri("https://api.example.com/")
    .body(Empty::<Bytes>::new())
    .unwrap();

let _resp = client.oneshot(req).await.expect("request ok");

Implementations

impl HttpClient

pub fn new(config: &HttpClientConfig) -> Result<Self, HttpClientError>

Creates a new HttpClient.

Returns an error if the TLS connector cannot be constructed.

pub fn builder(config: HttpClientConfig) -> HttpClientBuilder

Returns a builder for constructing an HttpClient with additional options.

Example

use std::sync::Arc;
use apollo_http_client::{HttpClient, HttpClientConfig};

let tls: Arc<rustls::ClientConfig> = todo!("build your ClientConfig");
let client = HttpClient::builder(HttpClientConfig::default())
    .with_tls_config(tls)
    .build()?;

Trait Implementations

impl Clone for HttpClient

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<B> Service<Request<B>> for HttpClient

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

fn call(&mut self, req: Request<B>) -> Self::Future

Sends an HTTP request to the URI specified in the request.

The URI must be absolute, including scheme and host. http://, https://, and (on Unix targets) unix:// route to the matching transport. A path-only URI like "/v1/data" returns HttpClientError::Request.

On non-Unix targets, unix:// returns HttpClientError::UnsupportedScheme.

type Response = Response<UnsyncBoxBody<Bytes, Box<dyn Error + Send + Sync>>>

Responses given by the service.

type Error = HttpClientError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<HttpClient as Service<Request<B>>>::Response, <HttpClient as Service<Request<B>>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.