Struct Client 

pub struct Client {
    inner: Rc<Inner>,
}

Client for making requests to pubhubs servers and hubs; cheaply clonable

Fields

inner: Rc<Inner>

Implementations

impl Client

pub async fn get_constellation(&self, url: &Url) -> Result<ConstellationOrId>

Retrieves Constellation from specified url, waiting for it to be set.

pub async fn try_get_stable_constellation( &self, phc_url: &Url, ) -> Result<Option<Constellation>>

Retrieves Constellation from all servers, and checks they coincide; returns None when there’s a disagreement.

impl Client

pub fn builder() -> Builder

Creates a new Builder.

pub fn http_client(&self) -> &Client

Returns the underlying awc::Client, for making raw HTTP requests.

pub fn query_with_retry<EP: EndpointDetails + 'static, BU, BR>( &self, server_url: BU, req: BR, ) -> impl Future<Output = EP::ResponseType> + use<EP, BU, BR>

where BU: Borrow<Url>, BR: Borrow<EP::RequestType>,

Like Client::query, but retries the query when it fails with a crate::api::ErrorInfo::retryable ErrorCode. When A queries B and B queries C, the B should, in general, not use Client::query_with_retry, but let A manage retries. This prevents A’s request from hanging without any explanation.

Unlike Client::query, the future returned by query_with_retry borrows server_url and req. (It does not borrow self.)

The borrowing of server_url and req by the returned future has the unfortunate side-effect that when the future is passed to, say, tokio::spawn, server_url and req are forced to have the 'static lifetime. In such cases it’s easiest to pass server_url and req not by reference, but by value - whence the use of the Borrow<T> trait, which is implemented both by T and &T.

pub fn query<'a, EP: EndpointDetails + 'static>( &self, server_url: &'a Url, req: impl Borrow<EP::RequestType> + 'a, ) -> QuerySetup<EP, &'a Url, impl Borrow<EP::RequestType>, HashMap<&'static str, Cow<'a, str>>, HeaderValue>

Sends a request to EP endpoint at server_url.

async fn query_inner<EP: EndpointDetails + 'static>( self, url: Url, req: SendClientRequest, quiet: bool, ) -> Result<EP::ResponseType>

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate of the value.

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

Performs copy-assignment from source.