Struct Client 

pub struct Client<S> { /* private fields */ }

Client struct to interact with a cluster for requests and subscriptions

S is the MembershipStorage implementation to fetch the cluster members

Implementations

impl<S> Client<S>

where S: 'static + MembershipStorage,

pub fn new(members_storage: S) -> Self

Create a new Client from a MembershipStorage

pub async fn send<T, E>( &mut self, handler_type: impl AsRef<str>, handler_id: impl AsRef<str>, payload: &(impl Serialize + IdentifiableType + Send + Sync), ) -> Result<T, RequestError<E>>

where T: DeserializeOwned, E: Error + DeserializeOwned + Clone + Send + Sync,

Send a request to the cluster transparently (the caller doesn’t need to know where the object is placed)

TODO

When the cached or selected server are not available, it needs to refresh all the cache and try a different server, this process needs to repeat until it finds a new available server

pub async fn send_request<E: Error + DeserializeOwned + Clone + Send + Sync>( &mut self, request: RequestEnvelope, ) -> Result<Vec<u8>, RequestError<E>>

Same as Self::send, but it uses the RequestEnvelope ready for serialization

pub async fn subscribe<'a, T>( &'a mut self, handler_type: impl AsRef<str>, handler_id: impl AsRef<str>, ) -> Result<impl Stream<Item = Result<T, ResponseError>> + 'a, ClientError>

where Self: 'a, T: DeserializeOwned + Unpin + 'a + Debug,

Subscribe to events from a service object

TODO

• Returns async iter
• Handle redirects
• Move this logic into a tower service
• Support moving service object (after you connect to a node and the handler you are listening to moves to some other node)
• Use dedicated connection

pub async fn ping(&mut self) -> Result<(), ClientError>

Connects to a the first server of the MembershipStorage

This is used mostly by the PeerToPeerClusterProvider to check whether a set of servers is reacheable and alive

Trait Implementations

impl<S: Clone> Clone for Client<S>

fn clone(&self) -> Client<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.