Struct sozu_lib::network::protocol::proxy_protocol::expect::ExpectProxyProtocol [−][src]
pub struct ExpectProxyProtocol<Front: SocketHandler> { pub frontend: Front, pub frontend_token: Token, pub front_buf: Checkout<BufferQueue>, pub readiness: Readiness, pub addresses: Option<ProxyAddr>, }
Fields
frontend: Front
frontend_token: Token
front_buf: Checkout<BufferQueue>
readiness: Readiness
addresses: Option<ProxyAddr>
Methods
impl<Front: SocketHandler + Read> ExpectProxyProtocol<Front>[src]
impl<Front: SocketHandler + Read> ExpectProxyProtocol<Front>pub fn new(
frontend: Front,
frontend_token: Token,
front_buf: Checkout<BufferQueue>
) -> Self[src]
pub fn new(
frontend: Front,
frontend_token: Token,
front_buf: Checkout<BufferQueue>
) -> Selfpub fn readable(
&mut self,
metrics: &mut SessionMetrics
) -> (ProtocolResult, ClientResult)[src]
pub fn readable(
&mut self,
metrics: &mut SessionMetrics
) -> (ProtocolResult, ClientResult)pub fn front_socket(&self) -> &TcpStream[src]
pub fn front_socket(&self) -> &TcpStreampub fn readiness(&mut self) -> &mut Readiness[src]
pub fn readiness(&mut self) -> &mut Readinesspub fn into_pipe(
self,
back_buf: Checkout<BufferQueue>,
backend_socket: Option<TcpStream>,
backend_token: Option<Token>
) -> Pipe<Front>[src]
pub fn into_pipe(
self,
back_buf: Checkout<BufferQueue>,
backend_socket: Option<TcpStream>,
backend_token: Option<Token>
) -> Pipe<Front>Auto Trait Implementations
impl<Front> Send for ExpectProxyProtocol<Front> where
Front: Send,
impl<Front> Send for ExpectProxyProtocol<Front> where
Front: Send, impl<Front> Sync for ExpectProxyProtocol<Front> where
Front: Sync,
impl<Front> Sync for ExpectProxyProtocol<Front> where
Front: Sync,