Struct NodeServiceClient 

pub struct NodeServiceClient(/* private fields */);

The client stub that makes RPC calls to the server. All request methods return Futures.

Implementations

impl NodeServiceClient

pub fn new<T>( config: Config, transport: T, ) -> NewClient<Self, RequestDispatch<NodeServiceRequest, NodeServiceResponse, T>>

where T: Transport<ClientMessage<NodeServiceRequest>, Response<NodeServiceResponse>>,

Returns a new client stub that sends requests over the given transport.

impl NodeServiceClient

pub fn get_node_rpc( &self, ctx: Context, ) -> impl Future<Output = Result<Node, RpcError>> + '_

pub fn get_predecessor_rpc( &self, ctx: Context, ) -> impl Future<Output = Result<Option<Node>, RpcError>> + '_

pub fn get_successor_rpc( &self, ctx: Context, ) -> impl Future<Output = Result<Node, RpcError>> + '_

pub fn get_successor_list_rpc( &self, ctx: Context, ) -> impl Future<Output = Result<Vec<Node>, RpcError>> + '_

pub fn find_successor_list_rpc( &self, ctx: Context, id: Digest, ) -> impl Future<Output = Result<Vec<Node>, RpcError>> + '_

pub fn find_predecessor_rpc( &self, ctx: Context, id: Digest, ) -> impl Future<Output = Result<Node, RpcError>> + '_

pub fn closest_preceding_finger_rpc( &self, ctx: Context, id: Digest, ) -> impl Future<Output = Result<Node, RpcError>> + '_

pub fn notify_rpc( &self, ctx: Context, node: Node, ) -> impl Future<Output = Result<(), RpcError>> + '_

pub fn stabilize_rpc( &self, ctx: Context, ) -> impl Future<Output = Result<(), RpcError>> + '_

pub fn get_local_rpc( &self, ctx: Context, key: Key, ) -> impl Future<Output = Result<Option<Value>, RpcError>> + '_

pub fn set_local_rpc( &self, ctx: Context, key: Key, value: Option<Value>, ) -> impl Future<Output = Result<(), RpcError>> + '_

pub fn get_rpc( &self, ctx: Context, key: Key, ) -> impl Future<Output = Result<Option<Value>, RpcError>> + '_

pub fn set_rpc( &self, ctx: Context, key: Key, value: Option<Value>, ) -> impl Future<Output = Result<(), RpcError>> + '_

pub fn replicate_rpc( &self, ctx: Context, key: Key, value: Option<Value>, ) -> impl Future<Output = Result<(), RpcError>> + '_

Trait Implementations

impl Clone for NodeServiceClient

fn clone(&self) -> NodeServiceClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeServiceClient

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

Formats the value using the given formatter.