[−][src]Struct sozu_lib::http::Session
Fields
app_id: Option<String>
listen_token: Token
Implementations
impl Session
[src]
pub fn new(
sock: TcpStream,
token: Token,
pool: Weak<RefCell<Pool<Buffer>>>,
public_address: SocketAddr,
expect_proxy: bool,
sticky_name: String,
timeout: Timeout,
answers: Rc<RefCell<HttpAnswers>>,
listen_token: Token,
delay: Duration
) -> Option<Session>
[src]
sock: TcpStream,
token: Token,
pool: Weak<RefCell<Pool<Buffer>>>,
public_address: SocketAddr,
expect_proxy: bool,
sticky_name: String,
timeout: Timeout,
answers: Rc<RefCell<HttpAnswers>>,
listen_token: Token,
delay: Duration
) -> Option<Session>
pub fn upgrade(&mut self) -> bool
[src]
pub fn set_answer(&mut self, answer: DefaultAnswerStatus, buf: Rc<Vec<u8>>)
[src]
pub fn http(&self) -> Option<&Http<TcpStream>>
[src]
pub fn http_mut(&mut self) -> Option<&mut Http<TcpStream>>
[src]
Trait Implementations
impl ProxyConfiguration<Session> for Proxy
[src]
fn connect_to_backend(
&mut self,
poll: &mut Poll,
session: &mut Session,
back_token: Token
) -> Result<BackendConnectAction, ConnectionError>
[src]
&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]
&mut self,
event_loop: &mut Poll,
message: ProxyRequest
) -> ProxyResponse
fn accept(&mut self, token: ListenToken) -> Result<TcpStream, AcceptError>
[src]
fn create_session(
&mut self,
frontend_sock: TcpStream,
listen_token: ListenToken,
poll: &mut Poll,
session_token: Token,
timeout: Timeout,
delay: Duration
) -> Result<(Rc<RefCell<Session>>, bool), AcceptError>
[src]
&mut self,
frontend_sock: TcpStream,
listen_token: ListenToken,
poll: &mut Poll,
session_token: Token,
timeout: Timeout,
delay: Duration
) -> Result<(Rc<RefCell<Session>>, bool), AcceptError>
fn listen_port_state(&self, port: &u16) -> ListenPortState
[src]
impl ProxySession for Session
[src]
fn close(&mut self, poll: &mut Poll) -> CloseResult
[src]
fn timeout(
&mut self,
token: Token,
timer: &mut Timer<Token>,
front_timeout: &Duration
) -> SessionResult
[src]
&mut self,
token: Token,
timer: &mut Timer<Token>,
front_timeout: &Duration
) -> SessionResult
fn cancel_timeouts(&self, timer: &mut Timer<Token>)
[src]
fn close_backend(&mut self, _: Token, poll: &mut Poll)
[src]
fn protocol(&self) -> Protocol
[src]
fn process_events(&mut self, token: Token, events: Ready)
[src]
fn ready(&mut self) -> SessionResult
[src]
fn shutting_down(&mut self) -> SessionResult
[src]
fn last_event(&self) -> SteadyTime
[src]
fn print_state(&self)
[src]
fn tokens(&self) -> Vec<Token>
[src]
impl ProxySessionCast for Session
[src]
Auto Trait Implementations
impl !RefUnwindSafe for Session
impl !Send for Session
impl !Sync for Session
impl Unpin for Session
impl !UnwindSafe for Session
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,