proxy_sdk

Trait StreamContext

Source 
pub trait StreamContext: BaseContext {
    // Provided methods
    fn on_new_connection(&mut self) -> FilterStreamStatus { ... }
    fn on_downstream_data(
        &mut self,
        data: &DownstreamData,
    ) -> FilterStreamStatus { ... }
    fn on_downstream_close(&mut self, data: &StreamClose) { ... }
    fn on_upstream_data(&mut self, data: &UpstreamData) -> FilterStreamStatus { ... }
    fn on_upstream_close(&mut self, data: &StreamClose) { ... }
}
Expand description

Trait to implement stream filters (L4 filters).

Provided Methods§

Source

fn on_new_connection(&mut self) -> FilterStreamStatus

Called on a new connection. TODO: FilterStreamStatus effect unknown.

Source

fn on_downstream_data(&mut self, data: &DownstreamData) -> FilterStreamStatus

Called when a chunk of downstream data is available. FilterStreamStatus::Pause will delay flushing of data until FilterStreamStatus::Continue is returned. TODO: resume_downstream might be able to trigger this from another context?

Source

fn on_downstream_close(&mut self, data: &StreamClose)

Called when a downstream connection closes.

Source

fn on_upstream_data(&mut self, data: &UpstreamData) -> FilterStreamStatus

Called when a chunk of upstream data is available. FilterStreamStatus::Pause will delay flushing of data until FilterStreamStatus::Continue is returned. TODO: resume_downstream might be able to trigger this from another context?

Source

fn on_upstream_close(&mut self, data: &StreamClose)

Called when an upstream connection closes.

Implementors§