Struct FjallEngine 

pub struct FjallEngine { /* private fields */ }

Available on crate feature fjall only.

Fjall-backed storage engine implementing all 6 storage traits.

Data directory layout:

• objects: {collection}\0{id} → serialized MemoryObject
• events: {stream}\0{seq:8BE} → serialized MemoryEvent
• queue_jobs: {queue}\0{id} → serialized QueueJob
• links_by_id: {link_id} → serialized Link
• links_from: {from_ref}\0{type}\0{link_id} → ()
• links_to: {to_ref}\0{type}\0{link_id} → ()

Implementations

impl FjallEngine

pub fn open(path: impl AsRef<Path>) -> Result<Self, Error>

Open or create a Fjall database at the given path. Creates all required keyspaces (partitions) on first open.

Trait Implementations

impl AggregateStore for FjallEngine

fn aggregate( &self, collection: &str, options: &AggregateOptions, ) -> ThingdResult<AggregateResult>

Run a general aggregation query over objects in a collection.

fn timeseries( &self, collection: &str, options: &TimeSeriesOptions, ) -> ThingdResult<TimeSeriesResult>

Run a time-bucketed aggregation query.

impl EventLog for FjallEngine

fn is_protected_stream(&self, stream: &str) -> bool

Returns true if the stream is protected from deletion and external mutation. Protected streams (e.g. "__thingd:mcp:audit") reject delete_last_event and delete_stream calls.

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 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.

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

Count total events across all streams.

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

List all unique stream names.

impl LinkStore for FjallEngine

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 FjallEngine

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

Insert or replace an object.

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 get_objects_batch( &self, collection: &str, ids: &[String], ) -> ThingdResult<Vec<Option<MemoryObject>>>

Read multiple objects by collection and id in a single query.

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 count_objects_in_collection(&self, collection: &str) -> ThingdResult<u64>

Count objects in a specific collection.

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

List all unique collection names.

fn create_index(&mut self, _collection: &str, _field: &str) -> ThingdResult<()>

Create a functional index on a JSON body field for a collection.

fn list_indexes(&self) -> ThingdResult<Vec<(String, String)>>

List all custom functional indexes.

fn schema( &self, collection: Option<&str>, options: &SchemaOptions, ) -> ThingdResult<Vec<CollectionSchema>>

Reflect the schema of all or one collection by sampling stored objects.

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

Insert or replace multiple objects in a single transaction.

impl QueueStore for FjallEngine

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 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 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(&mut self, queue: &str, id: &str) -> ThingdResult<Option<QueueJob>>

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

impl Searcher for FjallEngine

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

Search memory objects and event logs by query text.