Struct sozu_lib::network::protocol::pipe::Pipe

pub struct Pipe<Front: SocketHandler> {
    pub frontend: Front,
    pub front_buf: Checkout<BufferQueue>,
    pub app_id: Option<String>,
    pub request_id: String,
    pub readiness: Readiness,
    pub log_ctx: String,
    // some fields omitted
}

Fields

frontend: Front

front_buf: Checkout<BufferQueue>

app_id: Option<String>

request_id: String

readiness: Readiness

log_ctx: String

Methods

impl<Front: SocketHandler> Pipe<Front>

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

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 close(&mut self)

pub fn log_context(&self) -> String

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

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

pub fn front_hup(&mut self) -> ClientResult

pub fn back_hup(&mut self) -> ClientResult

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

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

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

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