Struct sozu_lib::protocol::proxy_protocol::expect::ExpectProxyProtocol
source · 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§
source§impl<Front: SocketHandler> ExpectProxyProtocol<Front>
impl<Front: SocketHandler> ExpectProxyProtocol<Front>
sourcepub fn new(
container_frontend_timeout: TimeoutContainer,
frontend: Front,
frontend_token: Token,
request_id: Ulid
) -> Self
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§
source§impl<Front: SocketHandler> SessionState for ExpectProxyProtocol<Front>
impl<Front: SocketHandler> SessionState for ExpectProxyProtocol<Front>
source§fn ready(
&mut self,
_session: Rc<RefCell<dyn ProxySession>>,
_proxy: Rc<RefCell<dyn L7Proxy>>,
metrics: &mut SessionMetrics
) -> SessionResult
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
source§fn update_readiness(&mut self, token: Token, events: Ready)
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
source§fn timeout(
&mut self,
token: Token,
_metrics: &mut SessionMetrics
) -> StateResult
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
source§fn cancel_timeouts(&mut self)
fn cancel_timeouts(&mut self)
cancel frontend timeout (and backend timeout if present)
source§fn print_state(&self, context: &str)
fn print_state(&self, context: &str)
display the session’s internal state (for debugging purpose), Read more
source§fn close(
&mut self,
_proxy: Rc<RefCell<dyn L7Proxy>>,
_metrics: &mut SessionMetrics
)
fn close( &mut self, _proxy: Rc<RefCell<dyn L7Proxy>>, _metrics: &mut SessionMetrics )
close the state
source§fn shutting_down(&mut self) -> bool
fn shutting_down(&mut self) -> bool
tell the session it has to shut down if possible Read more
Auto Trait Implementations§
impl<Front> Freeze for ExpectProxyProtocol<Front>where
Front: Freeze,
impl<Front> RefUnwindSafe for ExpectProxyProtocol<Front>where
Front: RefUnwindSafe,
impl<Front> Send for ExpectProxyProtocol<Front>where
Front: Send,
impl<Front> Sync for ExpectProxyProtocol<Front>where
Front: Sync,
impl<Front> Unpin for ExpectProxyProtocol<Front>where
Front: Unpin,
impl<Front> UnwindSafe for ExpectProxyProtocol<Front>where
Front: UnwindSafe,
Blanket Implementations§
source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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