Struct sozu_lib::protocol::proxy_protocol::expect::ExpectProxyProtocol

pub struct ExpectProxyProtocol<Front: SocketHandler> {
    pub addresses: Option<ProxyAddr>,
    pub container_frontend_timeout: TimeoutContainer,
    pub frontend_readiness: Readiness,
    pub frontend_token: Token,
    pub frontend: Front,
    pub request_id: Ulid,
    /* private fields */
}

Fields

addresses: Option<ProxyAddr>

container_frontend_timeout: TimeoutContainer

frontend_readiness: Readiness

frontend_token: Token

frontend: Front

request_id: Ulid

Implementations

impl<Front: SocketHandler> ExpectProxyProtocol<Front>

pub fn new( container_frontend_timeout: TimeoutContainer, frontend: Front, frontend_token: Token, request_id: Ulid ) -> Self

Instantiate a new ExpectProxyProtocol SessionState with:

• frontend_interest: READABLE | HUP | ERROR
• frontend_event: EMPTY

pub fn readable(&mut self, metrics: &mut SessionMetrics) -> SessionResult

pub fn front_socket(&self) -> &TcpStream

pub fn into_pipe( self, front_buf: Checkout, back_buf: Checkout, backend_socket: Option<TcpStream>, backend_token: Option<Token>, listener: Rc<RefCell<TcpListener>> ) -> Pipe<Front, TcpListener>

pub fn log_context(&self) -> LogContext<'_>

Trait Implementations

impl<Front: SocketHandler> SessionState for ExpectProxyProtocol<Front>

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