Struct sozu_lib::network::https_rustls::session::Session [−][src]
pub struct Session {
pub frontend_token: Token,
pub backend: Option<Rc<RefCell<Backend>>>,
pub back_connected: BackendConnectionStatus,
pub public_address: Option<IpAddr>,
pub metrics: SessionMetrics,
pub app_id: Option<String>,
pub listen_token: Token,
pub connection_attempt: u8,
// some fields omitted
}Fields
frontend_token: Token
backend: Option<Rc<RefCell<Backend>>>
back_connected: BackendConnectionStatus
public_address: Option<IpAddr>
metrics: SessionMetrics
app_id: Option<String>
listen_token: Token
connection_attempt: u8
Methods
impl Session[src]
impl Sessionpub fn new(
ssl: ServerSession,
sock: TcpStream,
token: Token,
pool: Weak<RefCell<Pool<BufferQueue>>>,
public_address: Option<IpAddr>,
expect_proxy: bool,
sticky_name: String,
timeout: Timeout,
listen_token: Token
) -> Session[src]
pub fn new(
ssl: ServerSession,
sock: TcpStream,
token: Token,
pool: Weak<RefCell<Pool<BufferQueue>>>,
public_address: Option<IpAddr>,
expect_proxy: bool,
sticky_name: String,
timeout: Timeout,
listen_token: Token
) -> Sessionpub fn http(&mut self) -> Option<&mut Http<FrontRustls>>[src]
pub fn http(&mut self) -> Option<&mut Http<FrontRustls>>pub fn set_answer(&mut self, answer: DefaultAnswerStatus, buf: Rc<Vec<u8>>)[src]
pub fn set_answer(&mut self, answer: DefaultAnswerStatus, buf: Rc<Vec<u8>>)pub fn upgrade(&mut self) -> bool[src]
pub fn upgrade(&mut self) -> boolpub fn log_context(&self) -> String[src]
pub fn log_context(&self) -> StringⓘImportant traits for TcpStreampub fn front_socket(&self) -> &TcpStream[src]
ⓘImportant traits for TcpStream
pub fn front_socket(&self) -> &TcpStreampub fn back_socket(&self) -> Option<&TcpStream>[src]
pub fn back_socket(&self) -> Option<&TcpStream>pub fn back_token(&self) -> Option<Token>[src]
pub fn back_token(&self) -> Option<Token>pub fn set_back_socket(&mut self, sock: TcpStream)[src]
pub fn set_back_socket(&mut self, sock: TcpStream)pub fn set_back_token(&mut self, token: Token)[src]
pub fn set_back_token(&mut self, token: Token)pub fn front_readiness(&mut self) -> &mut Readiness[src]
pub fn front_readiness(&mut self) -> &mut Readinesspub fn back_readiness(&mut self) -> Option<&mut Readiness>[src]
pub fn back_readiness(&mut self) -> Option<&mut Readiness>Trait Implementations
impl ProxySessionCast for Session[src]
impl ProxySessionCast for Sessionfn as_http(&mut self) -> &mut Session[src]
fn as_http(&mut self) -> &mut Sessionfn as_tcp(&mut self) -> &mut Session[src]
fn as_tcp(&mut self) -> &mut Sessionfn as_https_rustls(&mut self) -> &mut Session[src]
fn as_https_rustls(&mut self) -> &mut Sessionimpl ProxyConfiguration<Session> for Proxy[src]
impl ProxyConfiguration<Session> for Proxyfn accept(&mut self, token: ListenToken) -> Result<TcpStream, AcceptError>[src]
fn accept(&mut self, token: ListenToken) -> Result<TcpStream, AcceptError>fn create_session(
&mut self,
frontend_sock: TcpStream,
token: ListenToken,
poll: &mut Poll,
session_token: Token,
timeout: Timeout
) -> Result<(Rc<RefCell<Session>>, bool), AcceptError>[src]
fn create_session(
&mut self,
frontend_sock: TcpStream,
token: ListenToken,
poll: &mut Poll,
session_token: Token,
timeout: Timeout
) -> Result<(Rc<RefCell<Session>>, bool), AcceptError>fn connect_to_backend(
&mut self,
poll: &mut Poll,
session: &mut Session,
back_token: Token
) -> Result<BackendConnectAction, ConnectionError>[src]
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[src]
fn notify(
&mut self,
event_loop: &mut Poll,
message: ProxyRequest
) -> ProxyResponsefn listen_port_state(&self, port: &u16) -> ListenPortState[src]
fn listen_port_state(&self, port: &u16) -> ListenPortStateimpl ProxySession for Session[src]
impl ProxySession for Sessionfn close(&mut self, poll: &mut Poll) -> CloseResult[src]
fn close(&mut self, poll: &mut Poll) -> CloseResultfn timeout(
&self,
token: Token,
timer: &mut Timer<Token>,
front_timeout: &Duration
) -> SessionResult[src]
fn timeout(
&self,
token: Token,
timer: &mut Timer<Token>,
front_timeout: &Duration
) -> SessionResultfn cancel_timeouts(&self, timer: &mut Timer<Token>)[src]
fn cancel_timeouts(&self, timer: &mut Timer<Token>)fn close_backend(&mut self, _: Token, poll: &mut Poll)[src]
fn close_backend(&mut self, _: Token, poll: &mut Poll)fn protocol(&self) -> Protocol[src]
fn protocol(&self) -> Protocolfn process_events(&mut self, token: Token, events: Ready)[src]
fn process_events(&mut self, token: Token, events: Ready)fn ready(&mut self) -> SessionResult[src]
fn ready(&mut self) -> SessionResultfn last_event(&self) -> SteadyTime[src]
fn last_event(&self) -> SteadyTimefn print_state(&self)[src]
fn print_state(&self)fn tokens(&self) -> Vec<Token>[src]
fn tokens(&self) -> Vec<Token>