Struct SqliteThingStore 

pub struct SqliteThingStore { /* private fields */ }

Available on crate feature sqlite only.

SQLite-backed memory store.

Implementations

impl SqliteThingStore

pub fn open(path: impl AsRef<Path>) -> ThingdResult<Self>

Open a SQLite database file and initialize the schema.

Errors

Returns an error when SQLite cannot open the path or initialize schema.

pub fn open_in_memory() -> ThingdResult<Self>

Open an in-memory SQLite database and initialize the schema.

Errors

Returns an error when SQLite cannot initialize schema.

pub fn schema_version(&self) -> ThingdResult<u32>

Return the latest applied SQLite schema version.

Errors

Returns an error when the migration metadata cannot be read.

pub fn wal_checkpoint(&self) -> ThingdResult<(i32, i32)>

Run PRAGMA wal_checkpoint(TRUNCATE) to flush the WAL into the main database.

Returns (frames_before, frames_after) where frames_after should be 0 when the checkpoint fully succeeds.

Errors

Returns an error when SQLite fails to run the checkpoint.

pub fn close(&self) -> ThingdResult<()>

Close the database connection after running a WAL checkpoint.

Errors

Returns an error when the checkpoint fails.

pub fn backup_to(&self, path: &str) -> ThingdResult<()>

Create a consistent snapshot backup using VACUUM INTO.

The backup file will contain all data at the current point in time. The file can be opened with any SQLite client.

Errors

Returns an error when the destination path cannot be written.

Trait Implementations

impl EventLog for SqliteThingStore

fn append_event(&mut self, event: MemoryEvent) -> ThingdResult<MemoryEvent>

Append an event to a stream.

fn append_events_batch( &mut self, events: Vec<MemoryEvent>, ) -> ThingdResult<Vec<MemoryEvent>>

Append multiple events to a stream in a single transaction.

fn list_events( &self, stream: Option<&str>, options: ListEventsOptions, ) -> ThingdResult<Vec<MemoryEvent>>

List events, optionally filtered by stream, with pagination.

fn count_events(&self) -> ThingdResult<u64>

Count total events across all streams.

fn list_streams(&self) -> ThingdResult<Vec<String>>

List all unique stream names.

fn delete_last_event( &mut self, stream: &str, ) -> ThingdResult<Option<MemoryEvent>>

Delete the most recent event from a stream.

fn delete_stream(&mut self, stream: &str) -> ThingdResult<u64>

Delete all events in a stream.

impl LinkStore for SqliteThingStore

fn create_link(&mut self, link: Link) -> ThingdResult<Link>

Create a new graph link.

fn delete_link(&mut self, id: &str) -> ThingdResult<bool>

Delete a graph link by id.

fn get_link(&self, id: &str) -> ThingdResult<Option<Link>>

Get a graph link by id.

fn get_neighbors( &self, reference: &str, direction: LinkDirection, options: LinkQueryOptions, ) -> ThingdResult<Vec<Link>>

Get neighbors of a reference (outgoing, incoming, or both).

fn count_links(&self) -> ThingdResult<u64>

Count total links.

impl ObjectStore for SqliteThingStore

fn put_object(&mut self, object: MemoryObject) -> ThingdResult<MemoryObject>

Insert or replace an object.

fn put_objects_batch( &mut self, objects: Vec<MemoryObject>, ) -> ThingdResult<Vec<MemoryObject>>

Insert or replace multiple objects in a single transaction.

fn put_object_with_options( &mut self, object: MemoryObject, options: PutObjectOptions, ) -> ThingdResult<MemoryObject>

Insert or replace an object with explicit options.

fn get_object( &self, collection: &str, id: &str, ) -> ThingdResult<Option<MemoryObject>>

Read an object by collection and id.

fn list_objects( &self, collections: Option<&[String]>, options: &ListObjectsOptions, ) -> ThingdResult<Vec<MemoryObject>>

List objects in one or more collections, with optional filtering, limit, and offset.

fn delete_object(&mut self, collection: &str, id: &str) -> ThingdResult<bool>

Delete an object by collection and id.

fn delete_objects_batch( &mut self, keys: &[(String, String)], ) -> ThingdResult<u64>

Delete multiple objects in a single transaction.

fn count_objects(&self) -> ThingdResult<u64>

Count total objects across all collections.

fn list_collections(&self) -> ThingdResult<Vec<String>>

List all unique collection names.

impl QueueStore for SqliteThingStore

fn push_job(&mut self, job: QueueJob) -> ThingdResult<QueueJob>

Push a job onto a queue.

fn push_jobs_batch( &mut self, jobs: Vec<QueueJob>, ) -> ThingdResult<Vec<QueueJob>>

Push multiple jobs onto a queue in a single transaction.

fn claim_job_with_options( &mut self, queue: &str, options: QueueClaimOptions, ) -> ThingdResult<Option<QueueJob>>

Claim the next ready job from a queue with explicit options.

fn ack_job(&mut self, queue: &str, id: &str) -> ThingdResult<Option<QueueJob>>

Acknowledge a leased job as completed.

fn claim_and_ack( &mut self, queue: &str, options: QueueClaimOptions, ) -> ThingdResult<Option<QueueJob>>

Claim and immediately ack a job in a single transaction.

fn nack_job_with_options( &mut self, queue: &str, id: &str, options: QueueNackOptions, ) -> ThingdResult<Option<QueueJob>>

Reject a leased job for retry or dead-letter routing with explicit options.

fn list_jobs(&self, queue: &str) -> ThingdResult<Vec<QueueJob>>

List all jobs in a queue.

fn list_dead_jobs(&self, queue: &str) -> ThingdResult<Vec<QueueJob>>

List dead-letter jobs in a queue.

fn list_queues(&self) -> ThingdResult<Vec<String>>

List all unique queue names.

fn count_active_jobs(&self) -> ThingdResult<u64>

Count total active jobs across all queues.

fn count_dead_jobs(&self) -> ThingdResult<u64>

Count total dead-letter jobs across all queues.

fn claim_job(&mut self, queue: &str) -> ThingdResult<Option<QueueJob>>

Claim the next ready job from a queue.

fn nack_job(&mut self, queue: &str, id: &str) -> ThingdResult<Option<QueueJob>>

Reject a leased job for retry or dead-letter routing.

impl Searcher for SqliteThingStore

fn search( &self, query: &str, options: SearchOptions, ) -> ThingdResult<Vec<SearchHit>>

Search memory objects and event logs by query text.