Struct SqliteStore 

pub struct SqliteStore { /* private fields */ }

SQLite persistence store

Stores DDS samples in a SQLite database with efficient indexing.

Thread-safe via internal Mutex (SQLite Connection is not Sync).

Schema

CREATE TABLE samples (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    topic TEXT NOT NULL,
    type_name TEXT NOT NULL,
    payload BLOB NOT NULL,
    timestamp_ns INTEGER NOT NULL,
    sequence INTEGER NOT NULL,
    source_guid BLOB NOT NULL
);
CREATE INDEX idx_topic ON samples(topic);
CREATE INDEX idx_timestamp ON samples(timestamp_ns);

Implementations

impl SqliteStore

pub fn new(path: &str) -> Result<Self>

Create a new SQLite store with a file-based database

pub fn new_in_memory() -> Result<Self>

Create an in-memory SQLite store (for testing)

Trait Implementations

impl PersistenceStore for SqliteStore

fn save(&self, sample: &Sample) -> Result<()>

Save a sample to persistent storage

fn load(&self, topic: &str) -> Result<Vec<Sample>>

Load all samples for a topic

fn query_range( &self, topic: &str, start_ns: u64, end_ns: u64, ) -> Result<Vec<Sample>>

Query samples within a time range

fn apply_retention(&self, topic: &str, keep_count: usize) -> Result<()>

Delete old samples to enforce retention policy

fn apply_retention_policy( &self, topic: &str, policy: &RetentionPolicy, ) -> Result<()>

Apply retention policy with optional age/size constraints.

fn count(&self) -> Result<usize>

Get total number of samples stored

fn clear(&self) -> Result<()>

Clear all samples (for testing)