Struct sozu_lib::network::tcp::ServerConfiguration

pub struct ServerConfiguration { /* fields omitted */ }

Methods

impl ServerConfiguration

pub fn new(     event_loop: &mut Poll,     pool: Rc<RefCell<Pool<BufferQueue>>>,     tcp_listener: Vec<(AppId, TcpListener)>,     tokens: Vec<Token> ) -> (ServerConfiguration, HashSet<Token>)

pub fn give_back_listeners(&mut self) -> Vec<(String, TcpListener)>

pub fn add_tcp_front(     &mut self,     app_id: &str,     front: &SocketAddr,     event_loop: &mut Poll,     token: Token ) -> Option<ListenToken>

pub fn remove_tcp_front(     &mut self,     app_id: String,     event_loop: &mut Poll ) -> Option<ListenToken>

pub fn add_backend(     &mut self,     app_id: &str,     backend_id: &str,     backend_address: &SocketAddr,     sticky_id: Option<String>,     load_balancing_parameters: Option<LoadBalancingParams>,     event_loop: &mut Poll ) -> Option<ListenToken>

pub fn remove_backend(     &mut self,     app_id: &str,     backend_address: &SocketAddr,     event_loop: &mut Poll ) -> Option<ListenToken>

Trait Implementations

impl ProxyConfiguration<Client> for ServerConfiguration

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

fn notify(     &mut self,     event_loop: &mut Poll,     message: OrderMessage ) -> OrderMessageAnswer

fn accept(     &mut self,     token: ListenToken,     poll: &mut Poll,     client_token: Token ) -> Result<(Rc<RefCell<Client>>, bool), AcceptError>

fn accept_flush(&mut self) -> usize

fn close_backend(&mut self, app_id: String, addr: &SocketAddr)

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