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

pub struct ExpectProxyProtocol<Front: SocketHandler> {
    pub frontend: Front,
    pub frontend_token: Token,
    pub buf: [u8; 232],
    pub index: usize,
    pub header_len: HeaderLen,
    pub readiness: Readiness,
    pub addresses: Option<ProxyAddr>,
}

Fields

frontend: Front

frontend_token: Token

buf: [u8; 232]

index: usize

header_len: HeaderLen

readiness: Readiness

addresses: Option<ProxyAddr>

Methods

impl<Front: SocketHandler + Read> ExpectProxyProtocol<Front>

pub fn new(frontend: Front, frontend_token: Token) -> Self

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

Important traits for TcpStream

impl Write for TcpStreamimpl<'a> Write for &'a TcpStreamimpl<'a> Read for &'a TcpStreamimpl Read for TcpStream

pub fn front_socket(&self) -> &TcpStream

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

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