Struct sozu_lib::tcp::Proxy

pub struct Proxy { /* fields omitted */ }

Implementations

impl Proxy

pub fn new(backends: Rc<RefCell<BackendMap>>) -> Proxy

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

pub fn remove_listener(&mut self, address: SocketAddr) -> bool

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

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

pub fn give_back_listener(
    &mut self,
    address: SocketAddr
) -> Option<(Token, TcpListener)>

pub fn add_tcp_front(&mut self, app_id: &str, front: &SocketAddr) -> bool

pub fn remove_tcp_front(&mut self, front: SocketAddr) -> bool

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,
    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