Struct MemoryEngine 

pub struct MemoryEngine { /* private fields */ }

In-memory engine used to prove the storage boundary.

Examples

use thingd_core::{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 Default for MemoryEngine

fn default() -> MemoryEngine

Returns the “default value” for a type.

impl EventLog for MemoryEngine

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 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 get_object( &self, collection: &str, id: &str, ) -> ThingdResult<Option<MemoryObject>>

Read an object by collection and id.

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

List objects, optionally restricted to the provided collections.

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 list_collections(&self) -> ThingdResult<Vec<String>>

List all unique collection names.

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

Insert or replace multiple objects in a single transaction.

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

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

Search memory objects and event logs by query text.