Struct sozu_lib::network::protocol::http::Http

pub struct Http<Front: SocketHandler> {
    pub frontend: Front,
    pub backend: Option<TcpStream>,
    pub status: SessionStatus,
    pub state: Option<HttpState>,
    pub front_buf: Option<Checkout<BufferQueue>>,
    pub back_buf: Option<Checkout<BufferQueue>>,
    pub app_id: Option<String>,
    pub request_id: String,
    pub front_readiness: Readiness,
    pub back_readiness: Readiness,
    pub log_ctx: String,
    pub public_address: Option<IpAddr>,
    pub session_address: Option<SocketAddr>,
    pub sticky_name: String,
    pub sticky_session: Option<StickySession>,
    pub protocol: Protocol,
    // some fields omitted
}

Fields

frontend: Front

backend: Option<TcpStream>

status: SessionStatus

state: Option<HttpState>

front_buf: Option<Checkout<BufferQueue>>

back_buf: Option<Checkout<BufferQueue>>

app_id: Option<String>

request_id: String

front_readiness: Readiness

back_readiness: Readiness

log_ctx: String

public_address: Option<IpAddr>

session_address: Option<SocketAddr>

sticky_name: String

sticky_session: Option<StickySession>

protocol: Protocol

Methods

impl<Front: SocketHandler> Http<Front>

pub fn new(     sock: Front,     token: Token,     pool: Weak<RefCell<Pool<BufferQueue>>>,     public_address: Option<IpAddr>,     session_address: Option<SocketAddr>,     sticky_name: String,     protocol: Protocol ) -> Option<Http<Front>>

pub fn reset(&mut self)

pub fn reset_log_context(&mut self)

pub fn state(&mut self) -> &mut HttpState

pub fn set_state(&mut self, state: HttpState)

pub fn set_answer(&mut self, answer: DefaultAnswerStatus, buf: Rc<Vec<u8>>)

pub fn added_request_header(     &self,     public_address: Option<IpAddr>,     session_address: Option<SocketAddr> ) -> String

pub fn added_response_header(&self) -> String

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 back_socket(&self) -> Option<&TcpStream>

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

pub fn close(&mut self)

pub fn log_context(&self) -> String

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

pub fn set_app_id(&mut self, app_id: String)

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

pub fn clear_back_token(&mut self)

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

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

pub fn remove_backend(&mut self) -> (Option<String>, Option<SocketAddr>)

pub fn front_hup(&mut self) -> SessionResult

pub fn back_hup(&mut self) -> SessionResult

pub fn get_response_status(&self) -> Option<RStatusLine>

Retrieve the response status from the http response state

pub fn get_host(&self) -> Option<String>

pub fn get_request_line(&self) -> Option<RRequestLine>

pub fn get_session_address(&self) -> Option<SocketAddr>

pub fn get_backend_address(&self) -> Option<SocketAddr>

pub fn log_request_success(&self, metrics: &SessionMetrics)

pub fn log_default_answer_success(&self, metrics: &SessionMetrics)

pub fn log_request_error(&mut self, metrics: &mut SessionMetrics, message: &str)

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

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

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

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

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