Struct qiniu_http_client::HttpClient

pub struct HttpClient { /* private fields */ }

HTTP 客户端

用于发送 HTTP 请求的入口。

其中 HTTP 请求将由 HttpCaller 实现的实例来发送，如果不指定，默认通过当前启用的功能来判定。

私有云获取当前账户的 Buckets 列表

阻塞代码示例

use qiniu_credential::Credential;
use qiniu_http_client::{Authorization, HttpClient, Region, RegionsProviderEndpoints, ServiceName};

let region = Region::builder("z0")
    .add_uc_preferred_endpoint("uc-qos.pocdemo.qiniu.io".parse()?)
    .build();
let credential = Credential::new("abcdefghklmnopq", "1234567890");
let bucket_names: Vec<String> = HttpClient::default()
    .get(&[ServiceName::Uc], RegionsProviderEndpoints::new(region))
    .use_https(false)
    .authorization(Authorization::v2(credential))
    .accept_json()
    .path("/buckets")
    .call()?
    .parse_json()?
    .into_body();

异步代码示例

use qiniu_credential::Credential;
use qiniu_http_client::{Authorization, HttpClient, Region, RegionsProviderEndpoints, ServiceName};

let region = Region::builder("z0")
    .add_uc_preferred_endpoint("uc-qos.pocdemo.qiniu.io".parse()?)
    .build();
let credential = Credential::new("abcdefghklmnopq", "1234567890");
let bucket_names: Vec<String> = HttpClient::default()
    .async_get(&[ServiceName::Uc], RegionsProviderEndpoints::new(region))
    .use_https(false)
    .authorization(Authorization::v2(credential))
    .accept_json()
    .path("/buckets")
    .call()
    .await?
    .parse_json()
    .await?
    .into_body();

Implementations

impl HttpClient

pub fn ureq() -> Self

Available on crate feature ureq only.

创建一个新的 HTTP 客户端，使用 crate::ureq::Client 作为 HttpCaller 实现

pub fn isahc() -> Result<Self, IsahcError>

Available on crate feature isahc only.

创建一个新的 HTTP 客户端，使用 crate::isahc::Client 作为 HttpCaller 实现

pub fn reqwest_sync() -> Self

Available on crate feature reqwest only.

创建一个新的 HTTP 客户端，使用 crate::reqwest::SyncClient 作为 HttpCaller 实现

pub fn reqwest_async() -> Self

Available on crate features reqwest and async only.

创建一个新的 HTTP 客户端，使用 crate::reqwest::AsyncClient 作为 HttpCaller 实现

pub fn build_default() -> HttpClientBuilder

创建一个新的 HTTP 客户端，根据当前环境变量选择 HttpCaller 实现

pub fn build_ureq() -> HttpClientBuilder

Available on crate feature ureq only.

创建一个新的 HTTP 客户端构建器，使用 crate::ureq::Client 作为 HttpCaller 实现

pub fn build_isahc() -> Result<HttpClientBuilder, IsahcError>

Available on crate feature isahc only.

创建一个新的 HTTP 客户端构建器，使用 crate::isahc::Client 作为 HttpCaller 实现

pub fn build_reqwest_sync() -> HttpClientBuilder

Available on crate feature reqwest only.

创建一个新的 HTTP 客户端构建器，使用 crate::reqwest::SyncClient 作为 HttpCaller 实现

pub fn build_reqwest_async() -> HttpClientBuilder

Available on crate features reqwest and async only.

创建一个新的 HTTP 客户端构建器，使用 crate::reqwest::AsyncClient 作为 HttpCaller 实现

pub fn new(http_caller: impl HttpCaller + 'static) -> Self

创建一个新的 HTTP 客户端，需要指定 HttpCaller 实现

pub fn builder(http_caller: impl HttpCaller + 'static) -> HttpClientBuilder

创建一个新的 HTTP 客户端构建器，需要指定 HttpCaller 实现

pub fn get<'r, E: EndpointsProvider + 'r>(
    &'r self,
    service_names: &'r [ServiceName],
    endpoints_provider: E
) -> SyncRequestBuilder<'r, E>

创建 GET 请求的请求构建器

该方法的异步版本为 HttpClient::async_get。

pub fn post<'r, E: EndpointsProvider + 'r>(
    &'r self,
    service_names: &'r [ServiceName],
    endpoints_provider: E
) -> SyncRequestBuilder<'r, E>

创建 POST 请求的请求构建器

该方法的异步版本为 HttpClient::async_post。

pub fn put<'r, E: EndpointsProvider + 'r>(
    &'r self,
    service_names: &'r [ServiceName],
    endpoints_provider: E
) -> SyncRequestBuilder<'r, E>

创建 PUT 请求的请求构建器

该方法的异步版本为 HttpClient::async_put。

pub fn delete<'r, E: EndpointsProvider + 'r>(
    &'r self,
    service_names: &'r [ServiceName],
    endpoints_provider: E
) -> SyncRequestBuilder<'r, E>

创建 DELETE 请求的请求构建器

该方法的异步版本为 HttpClient::async_delete。

pub fn new_request<'r, E: EndpointsProvider + 'r>(
    &'r self,
    method: Method,
    service_names: &'r [ServiceName],
    endpoints_provider: E
) -> SyncRequestBuilder<'r, E>

创建请求的请求构建器

该方法的异步版本为 HttpClient::new_async_request。

pub fn async_get<'r, E: EndpointsProvider + 'r>(
    &'r self,
    service_names: &'r [ServiceName],
    endpoints_provider: E
) -> AsyncRequestBuilder<'r, E>

Available on crate feature async only.

创建 GET 请求的异步请求构建器

pub fn async_post<'r, E: EndpointsProvider + 'r>(
    &'r self,
    service_names: &'r [ServiceName],
    endpoints_provider: E
) -> AsyncRequestBuilder<'r, E>

Available on crate feature async only.

创建 POST 请求的异步请求构建器

pub fn async_put<'r, E: EndpointsProvider + 'r>(
    &'r self,
    service_names: &'r [ServiceName],
    endpoints_provider: E
) -> AsyncRequestBuilder<'r, E>

Available on crate feature async only.

创建 PUT 请求的异步请求构建器

pub fn async_delete<'r, E: EndpointsProvider + 'r>(
    &'r self,
    service_names: &'r [ServiceName],
    endpoints_provider: E
) -> AsyncRequestBuilder<'r, E>

Available on crate feature async only.

创建 DELETE 请求的异步请求构建器

pub fn new_async_request<'r, E: EndpointsProvider + 'r>(
    &'r self,
    method: Method,
    service_names: &'r [ServiceName],
    endpoints_provider: E
) -> AsyncRequestBuilder<'r, E>

创建异步请求的请求构建器

impl HttpClient

pub fn default_http_caller() -> Box<dyn HttpCaller>

获得默认的 HttpCaller 实例

默认通过当前启用的功能来判定

pub fn default_resolver() -> Box<dyn Resolver>

获得默认的 Resolver 实例

默认通过当前启用的功能来判定，并使用 CachedResolver 和 ShuffledResolver 对其进行包装。

pub fn default_chooser() -> Box<dyn Chooser>

获得默认的 Chooser 实例

默认使用 SubnetChooser，并使用 ShuffledChooser 和 NeverEmptyHandedChooser 对其进行包装。

pub fn default_retrier() -> Box<dyn RequestRetrier>

获得默认的 RequestRetrier 实例

默认使用 ErrorRetrier，并使用 LimitedRetrier 对其进行包装。

pub fn default_backoff() -> Box<dyn Backoff>

获得默认的 Backoff 实例

默认使用 ExponentialBackoff，并使用 LimitedBackoff 和 RandomizedBackoff 对其进行包装。

Trait Implementations

impl Clone for HttpClient

fn clone(&self) -> HttpClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for HttpClient

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

Formats the value using the given formatter.

impl Default for HttpClient

fn default() -> Self

Returns the “default value” for a type.