Struct WasmObservabilityPlugin 

pub struct WasmObservabilityPlugin { /* private fields */ }

Wrapper to use a WASM plugin as an ObservabilityExtension

Implementations

impl WasmObservabilityPlugin

pub fn new(instance: Arc<WasmPluginInstance>) -> Self

Create a new wrapper from a WASM instance

Trait Implementations

impl Extension for WasmObservabilityPlugin

fn info(&self) -> ExtensionInfo

Get extension information

fn as_any(&self) -> &dyn Any

Cast to Any for downcasting

fn as_any_mut(&mut self) -> &mut dyn Any

Cast to mutable Any for downcasting

fn init(&mut self) -> KernelResult<()>

Initialize the extension

fn shutdown(&mut self) -> KernelResult<()>

Shutdown the extension gracefully

impl ObservabilityExtension for WasmObservabilityPlugin

fn counter_inc(&self, name: &str, value: u64, labels: &[(&str, &str)])

Record a counter increment

fn gauge_set(&self, name: &str, value: f64, labels: &[(&str, &str)])

Record a gauge value

fn histogram_observe(&self, name: &str, value: f64, labels: &[(&str, &str)])

Record a histogram observation

fn span_start(&self, name: &str, parent: Option<u64>) -> u64

Start a new span

fn span_end(&self, span_id: u64)

End a span

fn span_event(&self, span_id: u64, name: &str, _attributes: &[(&str, &str)])

Add an event to a span

fn log_debug(&self, message: &str, fields: &[(&str, &str)])

Log at debug level

fn log_info(&self, message: &str, fields: &[(&str, &str)])

Log at info level

fn log_warn(&self, message: &str, fields: &[(&str, &str)])

Log at warn level

fn log_error(&self, message: &str, fields: &[(&str, &str)])

Log at error level

fn report_health(&self, health: &HealthInfo)

Report health status (called periodically by kernel)