Struct sozu_lib::https::HttpsProxy

pub struct HttpsProxy { /* private fields */ }

Implementations

impl HttpsProxy

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

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

pub fn remove_listener( &mut self, remove: RemoveListener ) -> Result<Option<ResponseContent>, ProxyError>

pub fn soft_stop(&mut self) -> Result<(), ProxyError>

pub fn hard_stop(&mut self) -> Result<(), ProxyError>

pub fn query_all_certificates( &mut self ) -> Result<Option<ResponseContent>, ProxyError>

pub fn query_certificate_for_domain( &mut self, domain: String ) -> Result<Option<ResponseContent>, ProxyError>

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

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

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

pub fn add_cluster( &mut self, cluster: Cluster ) -> Result<Option<ResponseContent>, ProxyError>

pub fn remove_cluster( &mut self, cluster_id: &str ) -> Result<Option<ResponseContent>, ProxyError>

pub fn add_https_frontend( &mut self, front: RequestHttpFrontend ) -> Result<Option<ResponseContent>, ProxyError>

pub fn remove_https_frontend( &mut self, front: RequestHttpFrontend ) -> Result<Option<ResponseContent>, ProxyError>

pub fn add_certificate( &mut self, add_certificate: AddCertificate ) -> Result<Option<ResponseContent>, ProxyError>

pub fn remove_certificate( &mut self, remove_certificate: RemoveCertificate ) -> Result<Option<ResponseContent>, ProxyError>

pub fn replace_certificate( &mut self, replace_certificate: ReplaceCertificate ) -> Result<Option<ResponseContent>, ProxyError>

Trait Implementations

impl L7Proxy for HttpsProxy

fn kind(&self) -> ListenerType

fn register_socket( &self, socket: &mut MioTcpStream, token: Token, interest: Interest ) -> Result<(), Error>

fn deregister_socket(&self, tcp_stream: &mut MioTcpStream) -> Result<(), Error>

fn add_session(&self, session: Rc<RefCell<dyn ProxySession>>) -> Token

fn remove_session(&self, token: Token) -> bool

Remove the session from the session manager slab. Returns true if the session was actually there before deletion

fn backends(&self) -> Rc<RefCell<BackendMap>>

fn clusters(&self) -> &HashMap<ClusterId, Cluster>

impl ProxyConfiguration for HttpsProxy

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>

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