Struct MemoryEngine 

pub struct MemoryEngine { /* private fields */ }

In-memory engine used to prove the storage boundary.

Examples

use thingd::{MemoryEngine, ObjectStore, EventLog, MemoryObject, MemoryEvent};

let mut engine = MemoryEngine::new();

engine.put_object(MemoryObject::new("users", "alice", r#"{"name":"Alice"}"#)).unwrap();
engine.append_event(MemoryEvent::new("audit", "login", r#"{"user":"alice"}"#)).unwrap();

assert_eq!(engine.count_objects().unwrap(), 1);
assert_eq!(engine.count_events().unwrap(), 1);

Implementations

impl MemoryEngine

pub fn new() -> Self

Create a new empty in-memory engine.

Trait Implementations

impl AggregateStore for MemoryEngine

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 Default for MemoryEngine

fn default() -> MemoryEngine

Returns the “default value” for a type.

impl EventLog for MemoryEngine

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

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

Append multiple events to a stream in a single transaction.

impl LinkStore for MemoryEngine

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 MemoryEngine

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 put_object_with_source_metadata( &mut self, object: MemoryObject, options: PutObjectOptions, ) -> ThingdResult<MemoryObject>

Apply an object received from a replication source while preserving the source metadata carried by the object. Normal application writes should continue to use put_object so the local store owns versioning.

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 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 create_index_definition( &mut self, index: IndexDefinition, ) -> ThingdResult<()>

Create or replace a functional index definition.

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

List all custom functional indexes.

fn delete_index(&mut self, collection: &str, field: &str) -> ThingdResult<bool>

Remove a functional index definition.

fn list_index_definitions(&self) -> ThingdResult<Vec<IndexDefinition>>

List index definitions, including uniqueness semantics.

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.

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 delete_objects_batch( &mut self, keys: &[(String, String)], ) -> ThingdResult<u64>

Delete multiple objects in a single transaction.

fn retain( &mut self, _options: RetentionOptions, ) -> ThingdResult<RetentionReport>

Apply explicit retention. Adapters that cannot safely compact return an unsupported-operation error rather than deleting records by default.

impl QueueStore for MemoryEngine

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

Push a job onto a queue.

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 push_jobs_batch( &mut self, jobs: Vec<QueueJob>, ) -> ThingdResult<Vec<QueueJob>>

Push multiple jobs onto a queue in a single transaction.

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 SchemaStore for MemoryEngine

fn get_schema_document(&self) -> ThingdResult<Option<StoredSchema>>

Read the last applied canonical schema, if any.

fn put_schema_document(&mut self, schema: StoredSchema) -> ThingdResult<()>

Store the canonical schema metadata.

fn list_migrations(&self) -> ThingdResult<Vec<MigrationRecord>>

List applied migrations in deterministic order.

fn record_migration(&mut self, migration: MigrationRecord) -> ThingdResult<()>

Record an applied migration.

impl Searcher for MemoryEngine

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

Search memory objects and event logs by query text.

impl ThingStore for MemoryEngine

fn recovery_budget(&self) -> RecoveryBudget

Return the configured bounded recovery budget.

fn fail_storage_recovery(&mut self, message: String)

Mark recovery failed without dropping durable data.

fn search_rebuild_required(&self) -> bool

Return whether the adapter has an asynchronous derived search rebuild that should be progressed by the hosting runtime.

fn search_rebuild_step(&mut self, _batch_size: usize) -> ThingdResult<bool>

Process one bounded asynchronous search rebuild batch.

fn retry_search_rebuild(&mut self) -> bool

Retry a degraded search rebuild when bounded recovery permits another generation.

fn search_rebuild_status(&self) -> Option<SearchRebuildStatus>

Available on crate feature persistent only.

Return backend-specific asynchronous search rebuild status, when supported.

fn storage_maintenance_status(&self) -> StorageMaintenanceStatus

Return backend-specific storage maintenance state.

fn compact_storage(&mut self) -> ThingdResult<()>

Compact the primary durable store when supported.

fn storage_diagnostics(&self) -> ThingdResult<StorageDiagnostics>

Return bounded storage diagnostics. Adapters may add backend-specific details through their own APIs without changing this stable summary.

impl VectorStore for MemoryEngine

fn vector_search( &self, collection: &str, query_vector: &[f32], options: VectorSearchOptions, ) -> ThingdResult<Vec<VectorSearchHit>>

Search objects by cosine similarity to the query vector.

fn add_vector( &mut self, collection: &str, id: &str, vector: &[f32], ) -> ThingdResult<()>

Add or update a vector for an object.

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

Remove a vector for an object.