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§
Sourcefn 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>
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.
Dyn Compatibility§
This trait is not dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.