Struct sozu_lib::network::protocol::proxy_protocol::relay::RelayProxyProtocol

pub struct RelayProxyProtocol<Front: SocketHandler> {
    pub header_size: Option<usize>,
    pub frontend: Front,
    pub backend: Option<TcpStream>,
    pub frontend_token: Token,
    pub backend_token: Option<Token>,
    pub front_buf: Checkout<BufferQueue>,
    pub readiness: Readiness,
    // some fields omitted
}

Fields

header_size: Option<usize>

frontend: Front

backend: Option<TcpStream>

frontend_token: Token

backend_token: Option<Token>

front_buf: Checkout<BufferQueue>

readiness: Readiness

Methods

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

pub fn new(     frontend: Front,     frontend_token: Token,     backend: Option<TcpStream>,     front_buf: Checkout<BufferQueue> ) -> Self

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

pub fn back_writable(     &mut self,     metrics: &mut SessionMetrics ) -> (ProtocolResult, ClientResult)

pub fn front_socket(&self) -> &TcpStream

pub fn back_socket(&self) -> Option<&TcpStream>

pub fn set_back_socket(&mut self, socket: TcpStream)

pub fn back_token(&self) -> Option<Token>

pub fn set_back_token(&mut self, token: Token)

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

pub fn into_pipe(self, back_buf: Checkout<BufferQueue>) -> Pipe<Front>