Struct TcpProxy

pub struct TcpProxy { /* private fields */ }

Implementations

impl TcpProxy

pub fn new( registry: Registry, sessions: Rc<RefCell<SessionManager>>, pool: Rc<RefCell<Pool>>, backends: Rc<RefCell<BackendMap>>, ) -> TcpProxy

pub fn add_listener( &mut self, config: TcpListenerConfig, token: Token, ) -> Result<Token, ProxyError>

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

pub fn activate_listener( &self, addr: &SocketAddr, tcp_listener: Option<MioTcpListener>, ) -> Result<Token, ProxyError>

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

pub fn give_back_listener( &mut self, address: SocketAddr, ) -> Result<(Token, MioTcpListener), ProxyError>

pub fn add_tcp_front( &mut self, front: RequestTcpFrontend, ) -> Result<(), ProxyError>

pub fn remove_tcp_front( &mut self, front: RequestTcpFrontend, ) -> Result<(), ProxyError>

Trait Implementations

impl ProxyConfiguration for TcpProxy

fn notify(&mut self, message: WorkerRequest) -> WorkerResponse

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

fn create_session( &mut self, frontend_sock: MioTcpStream, token: ListenToken, wait_time: Duration, proxy: Rc<RefCell<Self>>, ) -> Result<(), AcceptError>