Struct hadoop_common::ipc::ConnectionId

pub struct ConnectionId { /* private fields */ }

This class holds the address and the user ticket. The client connections to servers are uniquely identified by <remoteAddress, protocol, ticket>

Implementations

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>>

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.