Struct hadoop_common::ipc::Invoker

pub struct Invoker<T: RpcProtocol> { /* private fields */ }

Implementations

impl<T: RpcProtocol> Invoker<T>

pub fn from_socket_addr( addr: &SocketAddr, ticket: &UserGroupInformation, conf: &Configuration, rpc_timeout: i32, connection_retry_policy: Option<Rc<dyn RetryPolicy>>, fallback_to_simple_auth: Option<Arc<Atomic<bool>>>, alignment_context: Option<Rc<dyn AlignmentContext>> ) -> Result<Self>

pub fn from_connection_id( conn_id: Rc<ConnectionId>, conf: &Configuration, fallback_to_simple_auth: Option<Arc<Atomic<bool>>>, alignment_context: Option<Rc<dyn AlignmentContext>> ) -> Result<Self>

This constructor takes a connection_id, instead of creating a new one.

pub fn invoke<M: Default + Message>( &self, method: &str, the_request: &impl Message ) -> Result<M>

This is the client side invoker of RPC method.