Struct envoy_sdk::extension::access_logger::context::LoggerContext

pub struct LoggerContext<'a, L> where
    L: Logger,  { /* fields omitted */ }

Implementations

impl<'a, L> LoggerContext<'a, L> where
    L: Logger, 

pub fn new(
    logger: L,
    logger_ops: &'a dyn Ops,
    http_client_ops: &'a dyn ResponseOps
) -> LoggerContext<'a, L>

pub fn with_default_ops(logger: L) -> Self

Creates a new Access logger context bound to the actual Envoy ABI.

Trait Implementations

impl<'a, L> Context for LoggerContext<'a, L> where
    L: Logger, 

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, L> RootContext for LoggerContext<'a, L> where
    L: Logger, 

fn on_configure(&mut self, plugin_configuration_size: usize) -> bool

fn on_log(&mut self)

fn on_vm_start(&mut self, _vm_configuration_size: usize) -> bool

fn get_configuration(&self) -> Option<Vec<u8>>

fn set_tick_period(&self, period: Duration)

fn on_tick(&mut self)

fn on_queue_ready(&mut self, _queue_id: u32)

fn on_create_child_context(&mut self, _context_id: u32) -> Option<ChildContext>