Struct sozu_lib::network::http::Proxy

pub struct Proxy { /* fields omitted */ }

Methods

impl Proxy

pub fn new(pool: Rc<RefCell<Pool<BufferQueue>>>) -> Proxy

pub fn add_listener(     &mut self,     config: HttpListener,     pool: Rc<RefCell<Pool<BufferQueue>>>,     token: Token ) -> Option<Token>

pub fn activate_listener(     &mut self,     event_loop: &mut Poll,     addr: &SocketAddr,     tcp_listener: Option<TcpListener> ) -> Option<Token>

Important traits for Vec<u8>

impl Write for Vec<u8>

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

pub fn add_application(     &mut self,     application: Application,     event_loop: &mut Poll )

pub fn remove_application(&mut self, app_id: &str, event_loop: &mut Poll)

pub fn add_backend(     &mut self,     app_id: &str,     backend: Backend,     event_loop: &mut Poll )

pub fn remove_backend(     &mut self,     app_id: &str,     backend_address: &SocketAddr,     event_loop: &mut Poll )

pub fn backend_from_app_id(     &mut self,     session: &mut Session,     app_id: &str,     front_should_stick: bool ) -> Result<TcpStream, ConnectionError>

pub fn backend_from_sticky_session(     &mut self,     session: &mut Session,     app_id: &str,     sticky_session: String ) -> Result<TcpStream, ConnectionError>

Trait Implementations

impl ProxyConfiguration<Session> for Proxy

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

fn accept(&mut self, token: ListenToken) -> Result<TcpStream, AcceptError>

fn create_session(     &mut self,     frontend_sock: TcpStream,     listen_token: ListenToken,     poll: &mut Poll,     session_token: Token,     timeout: Timeout ) -> Result<(Rc<RefCell<Session>>, bool), AcceptError>

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