Struct sozu_lib::protocol::pipe::Pipe

pub struct Pipe<Front: SocketHandler, L: ListenerHandler> {
    pub frontend: Front,
    pub front_buf: Checkout,
    pub cluster_id: Option<String>,
    pub backend_id: Option<String>,
    pub request_id: Ulid,
    pub websocket_context: Option<String>,
    pub front_readiness: Readiness,
    pub back_readiness: Readiness,
    pub log_ctx: String,
    pub front_timeout: Option<TimeoutContainer>,
    pub back_timeout: Option<TimeoutContainer>,
    pub listener: Rc<RefCell<L>>,
    /* private fields */
}

Fields

frontend: Front

front_buf: Checkout

cluster_id: Option<String>

backend_id: Option<String>

request_id: Ulid

websocket_context: Option<String>

front_readiness: Readiness

back_readiness: Readiness

log_ctx: String

front_timeout: Option<TimeoutContainer>

back_timeout: Option<TimeoutContainer>

listener: Rc<RefCell<L>>

Implementations

impl<Front: SocketHandler, L: ListenerHandler> Pipe<Front, L>

pub fn new(
    frontend: Front,
    frontend_token: Token,
    request_id: Ulid,
    cluster_id: Option<String>,
    backend_id: Option<String>,
    websocket_context: Option<String>,
    backend: Option<TcpStream>,
    front_buf: Checkout,
    back_buf: Checkout,
    session_address: Option<SocketAddr>,
    protocol: Protocol,
    listener: Rc<RefCell<L>>
) -> Pipe<Front, L>

pub fn front_socket(&self) -> &TcpStream

pub fn front_socket_mut(&mut self) -> &mut TcpStream

pub fn back_socket(&self) -> Option<&TcpStream>

pub fn back_socket_mut(&mut self) -> Option<&mut TcpStream>

pub fn set_back_socket(&mut self, socket: TcpStream)

pub fn back_token(&self) -> Option<Token>

pub fn timeout(
    &mut self,
    token: Token,
    metrics: &mut SessionMetrics
) -> SessionResult

pub fn cancel_timeouts(&mut self)

pub fn close(&mut self)

pub fn set_cluster_id(&mut self, cluster_id: Option<String>)

pub fn set_backend_id(&mut self, backend_id: Option<String>)

pub fn reset_log_context(&mut self)

pub fn set_back_token(&mut self, token: Token)

pub fn front_readiness(&mut self) -> &mut Readiness

pub fn back_readiness(&mut self) -> &mut Readiness

pub fn get_session_address(&self) -> Option<SocketAddr>

pub fn get_backend_address(&self) -> Option<SocketAddr>

pub fn log_request_success(&self, metrics: &SessionMetrics)

pub fn log_request_error(&self, metrics: &SessionMetrics, message: &str)

pub fn check_connections(&self) -> bool

pub fn front_hup(&mut self, metrics: &mut SessionMetrics) -> SessionResult

pub fn back_hup(&mut self, metrics: &mut SessionMetrics) -> SessionResult

pub fn readable(&mut self, metrics: &mut SessionMetrics) -> SessionResult

pub fn writable(&mut self, metrics: &mut SessionMetrics) -> SessionResult

pub fn back_writable(&mut self, metrics: &mut SessionMetrics) -> SessionResult

pub fn back_readable(&mut self, metrics: &mut SessionMetrics) -> SessionResult

Trait Implementations

impl<Front: SocketHandler, L: ListenerHandler> Drop for Pipe<Front, L>

fn drop(&mut self)

Executes the destructor for this type.