oculus 0.1.3

Unified telemetry system for monitoring and observability
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

//! Storage Layer
//!
//! High-performance SQLite storage with async read/write separation:
//! - **Writer**: Async task with exclusive writes using tokio mpsc channel
//! - **Reader**: Connection pool for concurrent reads
//!
//! # Components
//!
//! - [`StorageWriter`]: Unified write facade for metrics and events via async channel
//! - [`MetricReader`] / [`EventReader`]: Async read facades
//! - [`CollectorStore`]: Collector configuration CRUD operations
//! - [`StorageAdmin`]: Cleanup and maintenance operations
//! - [`StorageBuilder`] / [`StorageHandles`]: Initialization and lifecycle management

mod actor;
mod builder;
pub mod collector_store;
pub mod db;
mod error;
mod facades;
mod schema;
mod types;

pub use builder::{StorageBuilder, StorageHandles};
pub use collector_store::{
    CollectorRecord, CollectorSource, CollectorStore, CollectorType, SyncResult,
};
pub use error::StorageError;
pub use facades::{
    CategoryStats, EventQuery, EventReader, MetricQuery, MetricReader, MetricResult, MetricStats,
    SortOrder, StorageAdmin, StorageWriter,
};
pub use types::{
    DynamicTags, Event, EventKind, EventPayload, EventSeverity, EventSource, MetricCategory,
    MetricSeries, MetricValue, StaticTags,
};