pub struct ConnectionId { /* private fields */ }
Expand description
This class holds the address and the user ticket. The client connections
to servers are uniquely identified by <remoteAddress, protocol, ticket>
Implementations§
Source§impl ConnectionId
impl ConnectionId
pub fn get_address(&self) -> &SocketAddr
pub fn get_ticket(&self) -> &UserGroupInformation
pub fn get_rpc_timeout(&self) -> i32
pub fn get_max_idle_time(&self) -> i32
pub fn get_max_retries_on_sasl(&self) -> i32
pub fn get_max_retries_on_socket_timeouts(&self) -> i32
pub fn get_tcp_no_delay(&self) -> bool
pub fn get_tcp_low_latency(&self) -> bool
pub fn get_do_ping(&self) -> bool
pub fn get_ping_interval(&self) -> i32
pub fn get_retry_policy(&self) -> Option<Rc<dyn RetryPolicy>>
Sourcepub fn get_connection_id(
addr: &SocketAddr,
ticket: &UserGroupInformation,
rpc_timeout: i32,
connection_retry_policy: Option<Rc<dyn RetryPolicy>>,
conf: &Configuration,
) -> Result<Self>
pub fn get_connection_id( addr: &SocketAddr, ticket: &UserGroupInformation, rpc_timeout: i32, connection_retry_policy: Option<Rc<dyn RetryPolicy>>, conf: &Configuration, ) -> Result<Self>
Returns a ConnectionId object.
Auto Trait Implementations§
impl Freeze for ConnectionId
impl !RefUnwindSafe for ConnectionId
impl !Send for ConnectionId
impl !Sync for ConnectionId
impl Unpin for ConnectionId
impl !UnwindSafe for ConnectionId
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