pf_observability_core 0.1.1

Core observability types and traits for the PromptFleet agent ecosystem
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65

use observability_core::domain::TraceContext;
use observability_core::{
    BasicMetricType, MetricsEntry, MetricsPort, ObservabilityResult, UnifiedWasmStdoutAdapter,
    WasmStdoutMetricsAdapter, create_counter_metric, create_histogram_metric,
};

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(())
}