Struct ExceptionBuffer 

pub struct ExceptionBuffer { /* private fields */ }

In-memory and SQLite-backed buffer for exception aggregation.

Concurrent writes go through the DashMap for lock-free aggregation. flush persists the in-memory state to SQLite, and load restores it on restart.

Examples

use exception_collector::{ExceptionBuffer, ExceptionRecord, ExceptionKind};

let buffer = ExceptionBuffer::new("/tmp/exceptions.db")?;
let record = ExceptionRecord::new("my-comp", ExceptionKind::Panic, "oops", "");
buffer.collect(record);
buffer.flush()?;

Implementations

impl ExceptionBuffer

pub fn new(db_path: &Path) -> Result<Self, BufferError>

Create a new buffer backed by a SQLite database at db_path.

The SQLite schema is created if it does not already exist. Call load afterwards to restore previous state.

Errors

Returns [BufferError::Sqlite] when the database cannot be opened or the schema cannot be created.

pub fn with_default_dir(component: &str) -> Result<Self, BufferError>

使用默认目录创建缓冲区，遵循以下优先级：

1. 环境变量 TOKENFLEET_EXCEPTIONS_DIR（如果设置）
2. 平台默认：
   • Linux / macOS: ~/.tokenfleet-ai/exceptions/
   • Windows: %APPDATA%/tokenfleet-ai/exceptions/

如果目标目录不存在会自动创建。

Errors

Returns [BufferError] when the data directory cannot be determined or the database cannot be created.

pub fn collect(&self, record: ExceptionRecord)

Aggregate an exception record into the in-memory buffer.

If the computed signature already exists, the count is incremented and last_seen is updated. Otherwise, a new aggregated entry is created with the record as the sample.

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

Persist all in-memory aggregated exceptions to SQLite.

Existing rows are upserted (insert-or-replace) so that both new entries and updated counts/timestamps are synced.

Errors

Returns [BufferError::Sqlite] or [BufferError::SerdeJson] when the persistence layer fails.

pub fn load(&self) -> Result<Vec<AggregatedException>, BufferError>

Load aggregated exceptions from SQLite into the in-memory buffer.

Intended to be called once at startup to recover state from the previous run. Entries already present in memory are overwritten by the SQLite version.

Errors

Returns [BufferError] when the database cannot be read.

pub fn mark_reported(&self, signatures: &[String]) -> Result<(), BufferError>

Mark the given signatures as reported in both memory and SQLite.

Signatures not present in the buffer are silently ignored.

Errors

Returns [BufferError::Sqlite] when the database update fails.

pub fn delete_reported_older_than( &self, cutoff: &DateTime<Utc>, ) -> Result<usize, BufferError>

Delete reported exceptions older than cutoff from the database.

Prevents unbounded disk growth by cleaning up old, already-reported data. Returns the number of deleted rows.

Errors

Returns [BufferError::Sqlite] when the database operation fails.

pub fn len(&self) -> usize

Return the number of distinct signatures in the in-memory buffer.

pub fn is_empty(&self) -> bool

Return true if the in-memory buffer contains no entries.

pub fn contains_signature(&self, signature: &str) -> bool

Check whether the given signature exists in the in-memory buffer.

pub fn unreported_samples(&self) -> Vec<ExceptionRecord>

Return all unreported sample records from the in-memory buffer.

Trait Implementations

impl Debug for ExceptionBuffer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.