Struct sozu_lib::network::http::Session

pub struct Session {
    pub app_id: Option<String>,
    pub listen_token: Token,
    // some fields omitted
}

Fields

app_id: Option<String>

listen_token: Token

Methods

impl Session

pub fn new(     sock: TcpStream,     token: Token,     pool: Weak<RefCell<Pool<BufferQueue>>>,     public_address: Option<IpAddr>,     expect_proxy: bool,     sticky_name: String,     timeout: Timeout,     listen_token: Token ) -> Option<Session>

pub fn upgrade(&mut self) -> bool

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

pub fn http(&mut self) -> Option<&mut Http<TcpStream>>

Trait Implementations

impl ProxySession for Session

fn close(&mut self, poll: &mut Poll) -> CloseResult

fn timeout(     &self,     token: Token,     timer: &mut Timer<Token>,     front_timeout: &Duration ) -> SessionResult

fn cancel_timeouts(&self, timer: &mut Timer<Token>)

fn close_backend(&mut self, _: Token, poll: &mut Poll)

fn protocol(&self) -> Protocol

fn process_events(&mut self, token: Token, events: Ready)

fn ready(&mut self) -> SessionResult

fn last_event(&self) -> SteadyTime

fn print_state(&self)

Important traits for Vec<u8>

impl Write for Vec<u8>

fn tokens(&self) -> Vec<Token>

impl ProxyConfiguration<Session> for Proxy

fn connect_to_backend(     &mut self,     poll: &mut Poll,     session: &mut Session,     back_token: Token ) -> Result<BackendConnectAction, ConnectionError>

fn notify(     &mut self,     event_loop: &mut Poll,     message: ProxyRequest ) -> ProxyResponse

fn accept(&mut self, token: ListenToken) -> Result<TcpStream, AcceptError>

fn create_session(     &mut self,     frontend_sock: TcpStream,     listen_token: ListenToken,     poll: &mut Poll,     session_token: Token,     timeout: Timeout ) -> Result<(Rc<RefCell<Session>>, bool), AcceptError>

fn listen_port_state(&self, port: &u16) -> ListenPortState

impl ProxySessionCast for Session

fn as_http(&mut self) -> &mut Session

fn as_tcp(&mut self) -> &mut Session

fn as_https_rustls(&mut self) -> &mut Session