Struct rpcx::client::Client

pub struct Client {
    pub opt: Opt,
    // some fields omitted
}

a direct client to connect rpcx services.

Fields

opt: Opt

Methods

impl Client

pub fn new(addr: &str) -> Client

pub fn start(&mut self) -> Result<(), Error>

pub fn send(
    &self,
    service_path: &str,
    service_method: &str,
    is_oneway: bool,
    is_heartbeat: bool,
    metadata: &HashMap<String, String, RandomState>,
    args: &dyn RpcxParam
) -> CallFuture

pub fn call<T>(
    &mut self,
    service_path: &str,
    service_method: &str,
    is_oneway: bool,
    metadata: &HashMap<String, String, RandomState>,
    args: &dyn RpcxParam
) -> Option<Result<T, Error>> where
    T: RpcxParam + Default, 

pub fn acall<T>(
    &mut self,
    service_path: &str,
    service_method: &str,
    metadata: &HashMap<String, String, RandomState>,
    args: &dyn RpcxParam
) -> Box<dyn Future<Item = Result<T, Error>, Error = Error> + 'static + Sync + Send> where
    T: RpcxParam + Default, 

Trait Implementations

impl Debug for Client

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

Formats the value using the given formatter.