pub struct ClientBuilder { /* private fields */ }
Expand description

Builder for Client.

Implementations§

source§

impl ClientBuilder

source

pub fn request_timeout(self, timeout: Duration) -> Self

Set request timeout (default is 60 seconds).

source

pub fn max_concurrent_requests(self, max: usize) -> Self

Set max concurrent requests (default is 256).

source

pub fn max_notifs_per_subscription(self, max: usize) -> Self

Set max concurrent notification capacity for each subscription; when the capacity is exceeded the subscription will be dropped (default is 1024).

You may prevent the subscription from being dropped by polling often enough Subscription::next() such that it can keep with the rate as server produces new items on the subscription.

Note: The actual capacity is num_senders + max_subscription_capacity because it is passed to futures_channel::mpsc::channel.

source

pub fn id_format(self, id_kind: IdKind) -> Self

Configure the data type of the request object ID (default is number).

source

pub fn set_max_logging_length(self, max: u32) -> Self

Set maximum length for logging calls and responses.

Logs bigger than this limit will be truncated.

source

pub fn ping_interval(self, interval: Duration) -> Self

Set the interval at which pings frames are submitted (disabled by default).

Periodically submitting pings at a defined interval has mainly two benefits:

  • Directly, it acts as a “keep-alive” alternative in the WebSocket world.
  • Indirectly by inspecting debug logs, it ensures that the endpoint is still responding to messages.

The underlying implementation does not make any assumptions about at which intervals pongs are received.

Note: The interval duration is restarted when

  • a frontend command is submitted
  • a reply is received from the backend
  • the interval duration expires
source

pub fn build_with_tokio<S, R>(self, sender: S, receiver: R) -> Clientwhere S: TransportSenderT + Send, R: TransportReceiverT + Send,

Build the client with given transport.

Panics

Panics if called outside of tokio runtime context.

Trait Implementations§

source§

impl Clone for ClientBuilder

source§

fn clone(&self) -> ClientBuilder

Returns a copy of the value. Read more
1.0.0 · source§

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

Performs copy-assignment from source. Read more
source§

impl Debug for ClientBuilder

source§

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

Formats the value using the given formatter. Read more
source§

impl Default for ClientBuilder

source§

fn default() -> Self

Returns the “default value” for a type. Read more
source§

impl Copy for ClientBuilder

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> Any for Twhere T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for Twhere T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for Twhere T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for Twhere U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> Same<T> for T

§

type Output = T

Should always be Self
source§

impl<T> ToOwned for Twhere T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

source§

fn vzip(self) -> V

source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

impl<T> MaybeSend for Twhere T: Send,