Struct AsyncClient 

pub struct AsyncClient { /* private fields */ }

Implementations

impl AsyncClient

pub async fn connect<A: ToSocketAddrs>(addr: A) -> Result<Self>

pub async fn call_json<P: AsRef<str>, T: Serialize>( &self, path: P, body: &T, ) -> Result<Value, RepeError>

pub async fn call_json_with_timeout<P: AsRef<str>, T: Serialize>( &self, path: P, body: &T, timeout_duration: Duration, ) -> Result<Value, RepeError>

Send a JSON request and fail if no response arrives before timeout_duration.

pub async fn call_typed_json<P: AsRef<str>, T: Serialize, R: DeserializeOwned>( &self, path: P, body: &T, ) -> Result<R, RepeError>

pub async fn call_typed_json_with_timeout<P: AsRef<str>, T: Serialize, R: DeserializeOwned>( &self, path: P, body: &T, timeout_duration: Duration, ) -> Result<R, RepeError>

Send a typed JSON request and fail if no response arrives before timeout_duration.

pub async fn call_typed_beve<P: AsRef<str>, T: Serialize, R: DeserializeOwned>( &self, path: P, body: &T, ) -> Result<R, RepeError>

pub async fn call_typed_beve_with_timeout<P: AsRef<str>, T: Serialize, R: DeserializeOwned>( &self, path: P, body: &T, timeout_duration: Duration, ) -> Result<R, RepeError>

Send a typed BEVE request and fail if no response arrives before timeout_duration.

pub async fn notify_json<P: AsRef<str>, T: Serialize>( &self, path: P, body: &T, ) -> Result<(), RepeError>

pub async fn notify_typed_json<P: AsRef<str>, T: Serialize>( &self, path: P, body: &T, ) -> Result<(), RepeError>

pub async fn notify_typed_beve<P: AsRef<str>, T: Serialize>( &self, path: P, body: &T, ) -> Result<(), RepeError>

pub async fn batch_json( &self, requests: Vec<(String, Value)>, ) -> Vec<Result<Value, RepeError>>

Execute JSON calls in parallel over this single connection and keep request order.

pub async fn batch_json_with_timeout( &self, requests: Vec<(String, Value)>, timeout_duration: Duration, ) -> Vec<Result<Value, RepeError>>

Execute JSON calls in parallel with a per-request timeout.

Trait Implementations

impl Clone for AsyncClient

fn clone(&self) -> AsyncClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.