Struct Mux 

pub struct Mux<Front: SocketHandler, L: ListenerHandler + L7ListenerHandler> {
    pub configured_frontend_timeout: Duration,
    pub frontend_token: Token,
    pub frontend: Connection<Front>,
    pub router: Router,
    pub context: Context<L>,
    pub session_ulid: Ulid,
}

Fields

configured_frontend_timeout: Duration

frontend_token: Token

frontend: Connection<Front>

router: Router

context: Context<L>

session_ulid: Ulid

Per-session correlation ID generated at construction time. Included in every log line emitted from this module so all events for a single frontend connection can be reassembled (independent of the ephemeral per-stream request id used by access logs).

Implementations

impl<Front: SocketHandler, L: ListenerHandler + L7ListenerHandler> Mux<Front, L>

pub fn front_socket(&self) -> &TcpStream

Trait Implementations

impl<Front: SocketHandler + Debug, L: ListenerHandler + L7ListenerHandler> SessionState for Mux<Front, L>

fn ready( &mut self, session: Rc<RefCell<dyn ProxySession>>, proxy: Rc<RefCell<dyn L7Proxy>>, _metrics: &mut SessionMetrics, ) -> SessionResult

if a session received an event or can still execute, the event loop will call this method. Its result indicates if it can still execute or if the session can be closed

fn update_readiness(&mut self, token: Token, events: Ready)

if the event loop got an event for a token associated with the session, it will call this method

fn timeout( &mut self, token: Token, _metrics: &mut SessionMetrics, ) -> StateResult

if a timeout associated with the session triggers, the event loop will call this method with the timeout’s token

fn cancel_timeouts(&mut self)

cancel frontend timeout (and backend timeout if present)

fn print_state(&self, _context: &str)

display the session’s internal state (for debugging purpose),

fn close( &mut self, proxy: Rc<RefCell<dyn L7Proxy>>, _metrics: &mut SessionMetrics, )

close the state

fn shutting_down(&mut self) -> bool

tell the session it has to shut down if possible