Struct EventStorage 

pub struct EventStorage { /* private fields */ }

SQLite storage for buffering telemetry events

Implementations

impl EventStorage

pub fn new(db_path: impl Into<PathBuf>) -> Result<Self>

Create a new event storage

Creates the storage directory and initializes the database schema.

pub fn in_memory() -> Result<Self>

Create an in-memory storage (for testing)

pub fn insert(&self, event: &Event) -> Result<()>

Insert an event into the storage

pub fn get_unsynced(&self, limit: usize) -> Result<Vec<Event>>

Get unsynced events (up to a limit)

pub fn mark_synced(&self, event_ids: &[Uuid]) -> Result<()>

Mark events as synced

pub fn increment_retry(&self, event_ids: &[Uuid]) -> Result<()>

Increment retry count for events

pub fn unsynced_count(&self) -> Result<usize>

Get count of unsynced events

pub fn cleanup_old_events(&self) -> Result<usize>

Delete old synced events (older than 7 days)

pub fn total_count(&self) -> Result<usize>

Get total event count

Trait Implementations

impl Send for EventStorage

impl Sync for EventStorage