Struct envoy_sdk::extension::filter::http::context::FilterContext

pub struct FilterContext<'a, F> where
    F: Filter,  { /* fields omitted */ }

Implementations

impl<'a, F> FilterContext<'a, F> where
    F: Filter, 

pub fn new(
    filter: F,
    filter_ops: &'a dyn Ops,
    http_client_ops: &'a dyn ResponseOps
) -> FilterContext<'a, F>

pub fn with_default_ops(filter: F) -> FilterContext<'a, F>

Creates a new HTTP filter context bound to the actual Envoy ABI.

Trait Implementations

impl<'a, F> Context for FilterContext<'a, F> where
    F: Filter, 

fn on_http_call_response(
    &mut self,
    token_id: u32,
    num_headers: usize,
    body_size: usize,
    num_trailers: usize
)

fn get_current_time(&self) -> SystemTime

fn get_property(&self, path: Vec<&str>) -> Option<Vec<u8>>

fn set_property(&self, path: Vec<&str>, value: Option<&[u8]>)

fn get_shared_data(&self, key: &str) -> (Option<Vec<u8>>, Option<u32>)

fn set_shared_data(
    &self,
    key: &str,
    value: Option<&[u8]>,
    cas: Option<u32>
) -> Result<(), Status>

fn register_shared_queue(&self, name: &str) -> u32

fn resolve_shared_queue(&self, vm_id: &str, name: &str) -> Option<u32>

fn dequeue_shared_queue(&self, queue_id: u32) -> Result<Option<Vec<u8>>, Status>

fn enqueue_shared_queue(
    &self,
    queue_id: u32,
    value: Option<&[u8]>
) -> Result<(), Status>

fn dispatch_http_call(
    &self,
    upstream: &str,
    headers: Vec<(&str, &str)>,
    body: Option<&[u8]>,
    trailers: Vec<(&str, &str)>,
    timeout: Duration
) -> Result<u32, Status>

fn get_http_call_response_headers(&self) -> Vec<(String, String)>

fn get_http_call_response_body(
    &self,
    start: usize,
    max_size: usize
) -> Option<Vec<u8>>

fn get_http_call_response_trailers(&self) -> Vec<(String, String)>

fn on_done(&mut self) -> bool

fn done(&self)

impl<'a, F> HttpContext for FilterContext<'a, F> where
    F: Filter, 

fn on_http_request_headers(&mut self, num_headers: usize) -> Action

fn on_http_request_body(
    &mut self,
    body_size: usize,
    end_of_stream: bool
) -> Action

fn on_http_request_trailers(&mut self, num_trailers: usize) -> Action

fn on_http_response_headers(&mut self, num_headers: usize) -> Action

fn on_http_response_body(
    &mut self,
    body_size: usize,
    end_of_stream: bool
) -> Action

fn on_http_response_trailers(&mut self, num_trailers: usize) -> Action

fn on_log(&mut self)

fn get_http_request_headers(&self) -> Vec<(String, String)>

fn set_http_request_headers(&self, headers: Vec<(&str, &str)>)

fn get_http_request_header(&self, name: &str) -> Option<String>

fn set_http_request_header(&self, name: &str, value: Option<&str>)

fn add_http_request_header(&self, name: &str, value: &str)

fn get_http_request_body(
    &self,
    start: usize,
    max_size: usize
) -> Option<Vec<u8>>

fn get_http_request_trailers(&self) -> Vec<(String, String)>

fn set_http_request_trailers(&self, trailers: Vec<(&str, &str)>)

fn get_http_request_trailer(&self, name: &str) -> Option<String>

fn set_http_request_trailer(&self, name: &str, value: Option<&str>)

fn add_http_request_trailer(&self, name: &str, value: &str)

fn resume_http_request(&self)

fn get_http_response_headers(&self) -> Vec<(String, String)>

fn set_http_response_headers(&self, headers: Vec<(&str, &str)>)

fn get_http_response_header(&self, name: &str) -> Option<String>

fn set_http_response_header(&self, name: &str, value: Option<&str>)

fn add_http_response_header(&self, name: &str, value: &str)

fn get_http_response_body(
    &self,
    start: usize,
    max_size: usize
) -> Option<Vec<u8>>

fn get_http_response_trailers(&self) -> Vec<(String, String)>

fn set_http_response_trailers(&self, headers: Vec<(&str, &str)>)

fn get_http_response_trailer(&self, name: &str) -> Option<String>

fn set_http_response_trailer(&self, name: &str, value: Option<&str>)

fn add_http_response_trailer(&self, name: &str, value: &str)

fn resume_http_response(&self)

fn send_http_response(
    &self,
    status_code: u32,
    headers: Vec<(&str, &str)>,
    body: Option<&[u8]>
)

fn clear_http_route_cache(&self)