Trait hadoop_common::ipc::RpcEngine

source · 
pub trait RpcEngine {
    // Required method
    fn get_proxy<T: RpcProtocol>(
        &self,
        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<T>;
}
Expand description

An RPC implementation.

Required Methods§

source

fn get_proxy<T: RpcProtocol>( &self, 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<T>

Construct a client-side proxy object.

Implementors§