Struct sozu_lib::network::server::Server [−][src]
pub struct Server {
pub poll: Poll,
// some fields omitted
}Fields
poll: Poll
Methods
impl Server[src]
impl Serverpub fn new_from_config(
channel: ProxyChannel,
scm: ScmSocket,
config: Config,
config_state: ConfigState
) -> Self[src]
pub fn new_from_config(
channel: ProxyChannel,
scm: ScmSocket,
config: Config,
config_state: ConfigState
) -> Selfpub fn new(
poll: Poll,
channel: ProxyChannel,
scm: ScmSocket,
sessions: Slab<Rc<RefCell<ProxySessionCast>>, SessionToken>,
pool: Rc<RefCell<Pool<BufferQueue>>>,
http: Option<Proxy>,
https: Option<HttpsProvider>,
tcp: Option<Proxy>,
server_config: ServerConfig,
config_state: Option<ConfigState>
) -> Self[src]
pub fn new(
poll: Poll,
channel: ProxyChannel,
scm: ScmSocket,
sessions: Slab<Rc<RefCell<ProxySessionCast>>, SessionToken>,
pool: Rc<RefCell<Pool<BufferQueue>>>,
http: Option<Proxy>,
https: Option<HttpsProvider>,
tcp: Option<Proxy>,
server_config: ServerConfig,
config_state: Option<ConfigState>
) -> Selfimpl Server[src]
impl Serverpub fn run(&mut self)[src]
pub fn run(&mut self)pub fn notify_proxys(&mut self, message: ProxyRequest)[src]
pub fn notify_proxys(&mut self, message: ProxyRequest)pub fn return_listen_sockets(&mut self)[src]
pub fn return_listen_sockets(&mut self)pub fn to_session(&self, token: Token) -> SessionToken[src]
pub fn to_session(&self, token: Token) -> SessionTokenpub fn from_session(&self, token: SessionToken) -> Token[src]
pub fn from_session(&self, token: SessionToken) -> Tokenpub fn close_session(&mut self, token: SessionToken)[src]
pub fn close_session(&mut self, token: SessionToken)pub fn create_session_tcp(
&mut self,
token: ListenToken,
socket: TcpStream
) -> bool[src]
pub fn create_session_tcp(
&mut self,
token: ListenToken,
socket: TcpStream
) -> boolpub fn create_session_http(
&mut self,
token: ListenToken,
socket: TcpStream
) -> bool[src]
pub fn create_session_http(
&mut self,
token: ListenToken,
socket: TcpStream
) -> boolpub fn create_session_https(
&mut self,
token: ListenToken,
socket: TcpStream
) -> bool[src]
pub fn create_session_https(
&mut self,
token: ListenToken,
socket: TcpStream
) -> boolpub fn accept(&mut self, token: ListenToken, protocol: Protocol)[src]
pub fn accept(&mut self, token: ListenToken, protocol: Protocol)pub fn create_sessions(&mut self)[src]
pub fn create_sessions(&mut self)pub fn connect_to_backend(&mut self, token: SessionToken)[src]
pub fn connect_to_backend(&mut self, token: SessionToken)pub fn interpret_session_order(
&mut self,
token: SessionToken,
order: SessionResult
)[src]
pub fn interpret_session_order(
&mut self,
token: SessionToken,
order: SessionResult
)pub fn ready(&mut self, token: Token, events: Ready)[src]
pub fn ready(&mut self, token: Token, events: Ready)pub fn timeout(&mut self, token: Token)[src]
pub fn timeout(&mut self, token: Token)pub fn handle_remaining_readiness(&mut self)[src]
pub fn handle_remaining_readiness(&mut self)