Struct hadoop_common::ipc::Client

pub struct Client { /* private fields */ }

A client for an IPC service. IPC calls take a single [Writable] as a parameter, and return a [Writable] as their value. A service runs on a port and is defined by a parameter class and a value class.

Implementations

impl Client

pub fn get_timeout(_conf: &Configuration) -> i32

pub fn new(value_class: &str, conf: &Configuration) -> Result<Self>

pub fn call<T: RpcProtocol>( &self, rpc_kind: &RpcKind, rpc_request: Rc<Vec<u8>>, remote_id: Rc<ConnectionId>, service_class: u8, fallback_to_simple_auth: Option<Arc<Atomic<bool>>>, alignment_context: Option<Rc<dyn AlignmentContext>> ) -> Result<Vec<u8>>

Make a call, passing rpc_request, to the IPC server defined by remote_id, returning the rpc response.