Struct Client 

pub struct Client { /* private fields */ }

An HTTP client for connectors. Cheap to clone; build one in new() and reuse it. See the module docs.

Implementations

impl Client

pub fn new() -> Result<Self, FaucetError>

A client with the ClientBuilder defaults.

pub fn builder() -> ClientBuilder

A builder.

pub fn inner(&self) -> &Client

The underlying reqwest client, for request shapes this type does not cover. It follows same-origin redirects only: a request sent straight from it gets a cross-origin 3xx back instead of following it. Send through send to follow those with credentials stripped.

pub fn request<U: IntoUrl>(&self, method: Method, url: U) -> RequestBuilder

Start a request.

pub fn get<U: IntoUrl>(&self, url: U) -> RequestBuilder

Start a GET.

pub fn post<U: IntoUrl>(&self, url: U) -> RequestBuilder

Start a POST.

pub fn put<U: IntoUrl>(&self, url: U) -> RequestBuilder

Start a PUT.

pub fn delete<U: IntoUrl>(&self, url: U) -> RequestBuilder

Start a DELETE.

pub fn head<U: IntoUrl>(&self, url: U) -> RequestBuilder

Start a HEAD.

pub fn max_response_bytes(&self) -> Option<u64>

The buffered-read limit.

pub async fn send( &self, request: RequestBuilder, ) -> Result<Response, FaucetError>

Send one attempt and follow its redirects. Any status comes back as a response; only a transport failure is an error.

pub async fn send_request( &self, request: Request, ) -> Result<Response, FaucetError>

send for an already-built request.

pub async fn execute<F>( &self, ctx: &CallContext, op: &'static str, build: F, ) -> Result<Response, FaucetError>

where F: FnMut() -> RequestBuilder,

Run a request as one backend call under ctx (CallContext::call): build is invoked once per attempt, a non-2xx response is an error (status_error) so a 5xx / 429 is retried by the context’s policy, and the 2xx response is returned.

pub async fn call( &self, ctx: &CallContext, op: &'static str, request: RequestBuilder, ) -> Result<Response, FaucetError>

Send request as one backend call under ctx and return the response whatever its status — for a connector that classifies statuses itself. Attempts are retried under the context’s policy only while the request can be re-sent; a streamed body goes out once.

pub async fn bytes(&self, resp: Response) -> Result<Vec<u8>, FaucetError>

Read the whole body, refusing one above the read limit.

pub async fn text(&self, resp: Response) -> Result<String, FaucetError>

Read the whole body as text (invalid UTF-8 replaced).

pub async fn json<T: DeserializeOwned>( &self, resp: Response, ) -> Result<T, FaucetError>

Read the whole body as JSON.

pub async fn json_value(&self, resp: Response) -> Result<Value, FaucetError>

A JSON response body as a Value with exact numbers: a literal the value would not spell again stays a string of its digits (crate::fidelity::from_slice).

Trait Implementations

impl Clone for Client

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Client

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

Formats the value using the given formatter.