Enum Connection 

pub enum Connection<Front: SocketHandler> {
    H1(ConnectionH1<Front>),
    H2(ConnectionH2<Front>),
}

Variants

H1(ConnectionH1<Front>)

H2(ConnectionH2<Front>)

Implementations

impl<Front: SocketHandler> Connection<Front>

pub fn new_h1_server( session_ulid: Ulid, front_stream: Front, timeout_container: TimeoutContainer, ) -> Connection<Front>

pub fn new_h1_client( session_ulid: Ulid, front_stream: Front, cluster_id: String, backend: Rc<RefCell<Backend>>, timeout_container: TimeoutContainer, ) -> Connection<Front>

pub fn new_h2_server( session_ulid: Ulid, front_stream: Front, pool: Weak<RefCell<Pool>>, timeout_container: TimeoutContainer, flood_config: H2FloodConfig, connection_config: H2ConnectionConfig, stream_idle_timeout: Duration, graceful_shutdown_deadline: Option<Duration>, ) -> Option<Connection<Front>>

pub fn new_h2_client( session_ulid: Ulid, front_stream: Front, cluster_id: String, backend: Rc<RefCell<Backend>>, pool: Weak<RefCell<Pool>>, timeout_container: TimeoutContainer, flood_config: H2FloodConfig, connection_config: H2ConnectionConfig, stream_idle_timeout: Duration, graceful_shutdown_deadline: Option<Duration>, ) -> Option<Connection<Front>>

pub fn readiness(&self) -> &Readiness

pub fn readiness_mut(&mut self) -> &mut Readiness

pub fn position(&self) -> &Position

pub fn position_mut(&mut self) -> &mut Position

pub fn socket(&self) -> &TcpStream

pub fn socket_mut(&mut self) -> &mut TcpStream

pub fn timeout_container(&mut self) -> &mut TimeoutContainer

pub fn overhead_bytes(&self) -> (usize, usize)

Returns connection-level byte overhead (bin, bout) for H2, (0, 0) for H1.

Trait Implementations

impl<Front: Debug + SocketHandler> Debug for Connection<Front>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.