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

pub struct Http<Front: SocketHandler> {
    pub frontend: Front,
    pub backend: Option<TcpStream>,
    pub status: ClientStatus,
    pub state: Option<HttpState>,
    pub front_buf: Checkout<BufferQueue>,
    pub back_buf: Checkout<BufferQueue>,
    pub app_id: Option<String>,
    pub request_id: String,
    pub readiness: Readiness,
    pub log_ctx: String,
    pub public_address: Option<IpAddr>,
    pub client_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: ClientStatus

state: Option<HttpState>

front_buf: Checkout<BufferQueue>

back_buf: Checkout<BufferQueue>

app_id: Option<String>

request_id: String

readiness: Readiness

log_ctx: String

public_address: Option<IpAddr>

client_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,     front_buf: Checkout<BufferQueue>,     back_buf: Checkout<BufferQueue>,     public_address: Option<IpAddr>,     client_address: Option<SocketAddr>,     sticky_name: String,     protocol: Protocol ) -> Option<Http<Front>>

pub fn reset(&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: &[u8])

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

pub fn added_response_header(&self) -> String

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

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

pub fn front_hup(&mut self) -> ClientResult

pub fn back_hup(&mut self) -> ClientResult

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_client_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(&self, metrics: &SessionMetrics, message: &str)

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

pub fn readable_parse(&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 ) -> (ProtocolResult, ClientResult)