Struct ObservabilityManager 

pub struct ObservabilityManager { /* private fields */ }

Central collector that receives events, applies privacy rules, aggregates metrics, and exports reports.

Implementations

impl ObservabilityManager

pub fn new(config: ObservabilityConfig) -> Arc<ObservabilityManager>

Creates a shared manager with bounded event buffering.

pub fn config(&self) -> &ObservabilityConfig

Returns the immutable configuration used by this manager.

pub fn start_span( self: &Arc<ObservabilityManager>, event_type: EventType, purpose: ObservationPurpose, ) -> SpanGuard

Starts a measured span for an LLM or tool wrapper.

pub fn record_lifecycle_event( &self, event_type: EventType, purpose: ObservationPurpose, status: EventStatus, duration_ms: u64, tags: HashMap<String, String>, payload: Option<Value>, )

Records hook-style lifecycle events that are not LLM or tool wrapper calls.

pub fn record_event(&self, event: ObservationEvent)

Queues a completed event without blocking the observed call path.

pub async fn flush(&self) -> Result<(), ObservabilityError>

Drains pending queued events into aggregation and raw buffers.

pub fn get_metrics(&self) -> Vec<AggregatedMetrics>

Returns configured aggregate metrics after draining pending events.

pub fn raw_events(&self) -> Vec<ObservationEvent>

Returns retained raw events after redaction and queue draining.

pub fn generate_report(&self) -> ObservabilityReport

Builds the user-facing report from the current rolling event window.

pub async fn export(&self) -> Result<ExportResult, ObservabilityError>

Writes configured report, aggregate, raw event, and Prometheus files.

pub fn dropped_events(&self) -> u64

Returns the total number of events dropped by bounded buffers.

pub fn redactor(&self) -> &Redactor

Returns the redactor used by wrappers for safe payload summaries.

pub fn build_event_from_span( &self, context: SpanContext, event_type: EventType, duration: Duration, status: EventStatus, tokens: Option<ObservationTokenUsage>, error: Option<ObservationError>, tags: HashMap<String, String>, payload: Option<Value>, ) -> ObservationEvent

Converts a completed SpanGuard into an ObservationEvent.

pub fn render_prometheus(&self) -> String

Renders current aggregate metrics in Prometheus text exposition format.

pub fn wants_format(&self, format: ExportFormat) -> bool

Returns true when a format is enabled in export.formats.