Struct sozu_lib::network::protocol::proxy_protocol::send::SendProxyProtocol

pub struct SendProxyProtocol<Front: SocketHandler> {
    pub header: Option<Vec<u8>>,
    pub frontend: Front,
    pub backend: Option<TcpStream>,
    pub frontend_token: Token,
    pub backend_token: Option<Token>,
    pub readiness: Readiness,
    // some fields omitted
}

Fields

header: Option<Vec<u8>>

frontend: Front

backend: Option<TcpStream>

frontend_token: Token

backend_token: Option<Token>

readiness: Readiness

Methods

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

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

pub fn back_writable(&mut self) -> (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 set_back_connected(&mut self, status: BackendConnectionStatus)

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

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