Struct sozu_lib::server::Server

pub struct Server {
    pub poll: Poll,
    /* private fields */
}

Server handles the event loop, the listeners, the sessions and communication with the configuration channel.

A listener wraps a listen socket, the associated proxying protocols (HTTP, HTTPS and TCP) and the routing configuration for clusters. Listeners handle creating sessions from accepted sockets.

A session manages a “front” socket for a connected client, and all of the associated data (back socket, protocol state machine, buffers, metrics…).

Server gets configuration updates from the channel (domIN/path routes, backend server address…).

Listeners and sessions are all stored in a slab structure to index them by a Token, they all have to implement the ProxySession trait.

Fields

poll: Poll

Implementations

impl Server

pub fn try_new_from_config(
    worker_to_main_channel: ProxyChannel,
    worker_to_main_scm: ScmSocket,
    config: Config,
    config_state: ConfigState,
    expects_initial_status: bool
) -> Result<Self>

pub fn new(
    poll: Poll,
    channel: ProxyChannel,
    scm: ScmSocket,
    sessions: Rc<RefCell<SessionManager>>,
    pool: Rc<RefCell<Pool>>,
    backends: Rc<RefCell<BackendMap>>,
    http: Option<Proxy>,
    https: Option<Proxy>,
    tcp: Option<Proxy>,
    server_config: ServerConfig,
    config_state: Option<ConfigState>,
    expects_initial_status: bool
) -> Result<Self>

pub fn run(&mut self)

pub fn notify_proxys(&mut self, request: ProxyRequest)

pub fn return_listen_sockets(&mut self)

Send all socket addresses and file descriptors of all proxies, via the scm socket

pub fn to_session(&self, token: Token) -> SessionToken

pub fn from_session(&self, token: SessionToken) -> Token

pub fn accept(&mut self, token: ListenToken, protocol: Protocol)

pub fn create_sessions(&mut self)

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

pub fn timeout(&mut self, token: Token)

pub fn handle_remaining_readiness(&mut self)