Struct sozu_lib::network::http::Client [−][src]
Fields
app_id: Option<String>
Methods
impl Client[src]
impl Clientpub fn new(
sock: TcpStream,
token: Token,
pool: Weak<RefCell<Pool<BufferQueue>>>,
public_address: Option<IpAddr>,
expect_proxy: bool,
sticky_name: String
) -> Option<Client>[src]
pub fn new(
sock: TcpStream,
token: Token,
pool: Weak<RefCell<Pool<BufferQueue>>>,
public_address: Option<IpAddr>,
expect_proxy: bool,
sticky_name: String
) -> Option<Client>pub fn upgrade(&mut self) -> bool[src]
pub fn upgrade(&mut self) -> boolpub fn set_answer(&mut self, answer: DefaultAnswerStatus, buf: &[u8])[src]
pub fn set_answer(&mut self, answer: DefaultAnswerStatus, buf: &[u8])pub fn http(&mut self) -> Option<&mut Http<TcpStream>>[src]
pub fn http(&mut self) -> Option<&mut Http<TcpStream>>Trait Implementations
impl ProxyClient for Client[src]
impl ProxyClient for Clientfn close(&mut self, poll: &mut Poll) -> CloseResult[src]
fn close(&mut self, poll: &mut Poll) -> CloseResultfn close_backend(
&mut self,
_: Token,
poll: &mut Poll
) -> Option<(String, SocketAddr)>[src]
fn close_backend(
&mut self,
_: Token,
poll: &mut Poll
) -> Option<(String, SocketAddr)>fn protocol(&self) -> Protocol[src]
fn protocol(&self) -> Protocolfn process_events(&mut self, token: Token, events: Ready)[src]
fn process_events(&mut self, token: Token, events: Ready)fn ready(&mut self) -> ClientResult[src]
fn ready(&mut self) -> ClientResultimpl ProxyConfiguration<Client> for ServerConfiguration[src]
impl ProxyConfiguration<Client> for ServerConfigurationfn connect_to_backend(
&mut self,
poll: &mut Poll,
client: &mut Client,
back_token: Token
) -> Result<BackendConnectAction, ConnectionError>[src]
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[src]
fn notify(
&mut self,
event_loop: &mut Poll,
message: OrderMessage
) -> OrderMessageAnswerfn accept(
&mut self,
token: ListenToken,
poll: &mut Poll,
client_token: Token
) -> Result<(Rc<RefCell<Client>>, bool), AcceptError>[src]
fn accept(
&mut self,
token: ListenToken,
poll: &mut Poll,
client_token: Token
) -> Result<(Rc<RefCell<Client>>, bool), AcceptError>fn accept_flush(&mut self) -> usize[src]
fn accept_flush(&mut self) -> usizefn close_backend(&mut self, app_id: String, addr: &SocketAddr)[src]
fn close_backend(&mut self, app_id: String, addr: &SocketAddr)fn listen_port_state(&self, port: &u16) -> ListenPortState[src]
fn listen_port_state(&self, port: &u16) -> ListenPortStateimpl ProxyClientCast for Client[src]
impl ProxyClientCast for Client