Trait proxy_wasm::traits::Context

pub trait Context {
    fn get_current_time(&self) -> SystemTime { ... }
    fn get_property(&self, path: Vec<&str>) -> Option<Bytes> { ... }
    fn set_property(&self, path: Vec<&str>, value: Option<&[u8]>) { ... }
    fn get_shared_data(&self, key: &str) -> (Option<Bytes>, 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<Bytes>, 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 on_http_call_response(
        &mut self, 
        _token_id: u32, 
        _num_headers: usize, 
        _body_size: usize, 
        _num_trailers: usize
    ) { ... }
    fn get_http_call_response_headers(&self) -> Vec<(String, String)> { ... }
    fn get_http_call_response_body(
        &self, 
        start: usize, 
        max_size: usize
    ) -> Option<Bytes> { ... }
    fn get_http_call_response_trailers(&self) -> Vec<(String, String)> { ... }
    fn on_done(&mut self) -> bool { ... }
    fn done(&self) { ... }
}

Provided methods

fn get_current_time(&self) -> SystemTime

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

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

fn get_shared_data(&self, key: &str) -> (Option<Bytes>, 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<Bytes>, 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 on_http_call_response(
    &mut self,
    _token_id: u32,
    _num_headers: usize,
    _body_size: usize,
    _num_trailers: usize
)

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

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

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

fn on_done(&mut self) -> bool

fn done(&self)

Loading content...

Implementors

Loading content...