Struct hadoop_common::ipc::RPC
source · pub struct RPC;Expand description
A simple RPC mechanism.
Implementations§
source§impl RPC
impl RPC
pub const RPC_SERVICE_CLASS_DEFAULT: u8 = 0u8
sourcepub fn get_protocol_name<T: RpcProtocol>() -> &'static str
pub fn get_protocol_name<T: RpcProtocol>() -> &'static str
Get the protocol name.
sourcepub fn get_protocol_version<T: RpcProtocol>() -> u64
pub fn get_protocol_version<T: RpcProtocol>() -> u64
Get the protocol version from protocol class.
sourcepub fn get_protocol_proxy<T: RpcProtocol>(
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>
pub fn get_protocol_proxy<T: RpcProtocol>( 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>
Get a protocol proxy that contains a proxy connection to a remote server and a set of methods that are supported by the server.
Auto Trait Implementations§
impl RefUnwindSafe for RPC
impl Send for RPC
impl Sync for RPC
impl Unpin for RPC
impl UnwindSafe for RPC
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more