Struct UnifiedWasmStdoutAdapter 

pub struct UnifiedWasmStdoutAdapter { /* private fields */ }

Extended WASM adapter that handles both logs and metrics with correlation

Implementations

impl UnifiedWasmStdoutAdapter

pub fn new() -> Self

Examples found in repository

examples/basic_metrics_demo.rs (line 27)

fn main() -> ObservabilityResult<()> {
    println!("🎯 Basic MetricsPort Demo");

    // Create simple metrics adapter
    let metrics_adapter = WasmStdoutMetricsAdapter::new();

    println!("\n📊 Testing simple metrics emission:");

    // Test counter
    metrics_adapter.emit_counter_simple("requests_total", 1.0)?;

    // Test histogram
    metrics_adapter.emit_histogram_simple("request_duration_ms", 150.0)?;

    // Test gauge
    metrics_adapter.emit_gauge_simple("active_connections", 5.0)?;

    println!("\n🔄 Testing unified adapter (logs + metrics correlation):");

    // Create unified adapter for correlation
    let unified_adapter = UnifiedWasmStdoutAdapter::new();

    // Test correlated metrics
    unified_adapter.emit_counter_simple("llm_requests", 1.0)?;
    unified_adapter.emit_histogram_simple("llm_response_time_ms", 2500.0)?;

    println!("\n📈 Testing MetricsEntry with trace context:");

    // Create metrics with trace context for correlation
    let trace_context = TraceContext {
        trace_id: "trace-123456".to_string(),
        span_id: "span-789".to_string(),
        parent_span_id: Some("parent-456".to_string()),
    };

    let counter_metric = create_counter_metric("a2a_messages_sent", 3.0)
        .with_trace_context(trace_context.clone())
        .with_source(
            Some("a2a_jsonrpc_core".to_string()),
            Some("message_handler".to_string()),
            Some("send_request".to_string()),
        );

    println!("Metric with context: {}", counter_metric.to_json());

    let histogram_metric = create_histogram_metric("template_render_duration_us", 1250.0)
        .with_trace_context(trace_context)
        .with_source(
            Some("template_engines".to_string()),
            Some("sailfish_renderer".to_string()),
            Some("render_template".to_string()),
        );

    println!("Metric with context: {}", histogram_metric.to_json());

    println!("\n✅ Basic metrics demo completed!");

    Ok(())
}

pub fn transport_metric(&self, entry: &MetricsEntry) -> ObservabilityResult<()>

Process metrics entry through same formatting as logs for correlation

Trait Implementations

impl Default for UnifiedWasmStdoutAdapter

fn default() -> Self

Returns the “default value” for a type.

impl MetricsPort for UnifiedWasmStdoutAdapter

fn emit_counter_simple(&self, name: &str, value: f64) -> ObservabilityResult<()>

Emit a simple counter metric

fn emit_histogram_simple( &self, name: &str, value: f64, ) -> ObservabilityResult<()>

Emit a simple histogram/timing metric

fn emit_gauge_simple(&self, name: &str, value: f64) -> ObservabilityResult<()>

Emit a simple gauge metric

fn is_enabled(&self) -> bool

Check if metrics collection is enabled

fn emit_metrics_batch( &self, entries: &[MetricsEntry], ) -> ObservabilityResult<()>

Batch emit multiple metrics (optional, has default implementation)

impl TransportPort for UnifiedWasmStdoutAdapter

fn transport(&self, entry: &LogEntry) -> ObservabilityResult<()>

Transport a single log entry

fn transport_batch(&self, entries: &[LogEntry]) -> ObservabilityResult<()>

Transport multiple log entries (for batching)