pf_observability_core 0.1.0

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
66
67
68
69
70
71
72
73
74
75

//! # Observability Core
//!
//! Core traits and foundational components for structured logging and observability.
//! This crate provides zero-cost abstractions for telemetry, metrics, and structured logging
//! that can be conditionally compiled based on feature flags.
//!
//! ## Features
//!
//! - `observability`: Enables all observability features
//! - `otel-2025`: OpenTelemetry 2025 integration
//! - `structured-logging`: JSON structured logging support
//! - `prometheus-federation`: Prometheus metrics federation
//! - `auto-instrumentation`: Automatic instrumentation capabilities

pub mod batching;
pub mod context;
pub mod error;
pub mod noop;
pub mod traits;

// Core hexagonal architecture modules for standard logging integration
pub mod adapters;
pub mod domain;
pub mod extension;
pub mod ports;

// Re-export commonly used types
pub use batching::{BatchingConfig, BatchingManager};
pub use context::{
    ContextFuture,
    HeaderExtractor,
    // Header utilities
    HeaderInjector,
    TraceContext,
    W3CTraceContext,
    clear_current_context,
    get_current_context,
    // Thread-local management
    set_current_context,
    with_context,
    with_context_future,
};
pub use error::{ObservabilityError, ObservabilityResult};
pub use noop::NoOpObservabilityPlugin;
pub use traits::{
    LogLevel, MetricsCollector, ObservabilityPlugin, SpanGuard, SpanStatus, StructuredLogger,
};

// Re-export hexagonal architecture types
pub use adapters::{
    CompactJsonFormatter, JsonFormatter, LogDirectives, StandardLogAdapter,
    UnifiedWasmStdoutAdapter, WasmStdoutAdapter, WasmStdoutMetricsAdapter,
};
#[cfg(feature = "structured-logging")]
pub use adapters::{TracingIntegrationBuilder, TracingSubscriberAdapter};
pub use domain::{
    BasicMetricType, EnhancedContextEnricher, LogEntry, LogKvExtractor, MetricsEntry,
    MetricsSource, ProcessorChain, TraceCorrelation, create_counter_metric, create_gauge_metric,
    create_histogram_metric,
};
pub use extension::{
    GlobalLoggerSingleton, ObservabilityConfig, ObservabilityManager, create_observability_manager,
};
pub use ports::{
    BatchingPort, ContextPort, FormatterPort, MetricsPort, StandardLoggingPort, TransportPort,
};

/// Version information for the observability core
pub const VERSION: &str = env!("CARGO_PKG_VERSION");

/// Default batch size for telemetry data
pub const DEFAULT_BATCH_SIZE: usize = 100;

/// Default flush interval in seconds
pub const DEFAULT_FLUSH_INTERVAL_SECS: u64 = 5;