Trait ObjectStore 

pub trait ObjectStore {
    // Required methods
    fn put_object(&mut self, object: MemoryObject) -> ThingdResult<MemoryObject>;
    fn get_object(
        &self,
        collection: &str,
        id: &str,
    ) -> ThingdResult<Option<MemoryObject>>;
    fn list_objects(
        &self,
        collections: Option<&[String]>,
        options: &ListObjectsOptions,
    ) -> ThingdResult<Vec<MemoryObject>>;
    fn delete_object(
        &mut self,
        collection: &str,
        id: &str,
    ) -> ThingdResult<bool>;
    fn count_objects(&self) -> ThingdResult<u64>;
    fn list_collections(&self) -> ThingdResult<Vec<String>>;

    // Provided methods
    fn put_objects_batch(
        &mut self,
        objects: Vec<MemoryObject>,
    ) -> ThingdResult<Vec<MemoryObject>> { ... }
    fn put_object_with_options(
        &mut self,
        object: MemoryObject,
        options: PutObjectOptions,
    ) -> ThingdResult<MemoryObject> { ... }
    fn delete_objects_batch(
        &mut self,
        keys: &[(String, String)],
    ) -> ThingdResult<u64> { ... }
}

Object storage operations.

Examples

use thingd_core::{MemoryEngine, ObjectStore, MemoryObject};

let mut store = MemoryEngine::new();
let obj = MemoryObject::new("users", "alice", r#"{"name":"Alice"}"#);
store.put_object(obj).unwrap();

let user = store.get_object("users", "alice").unwrap();
assert!(user.is_some());
assert_eq!(store.count_objects().unwrap(), 1);

Required Methods

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

Insert or replace an object.

Errors

Returns an error when the backing store cannot persist the object.

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

Read an object by collection and id.

Errors

Returns an error when the backing store cannot read the object.

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.

Pass an empty ListObjectsOptions to return all objects across all collections.

Errors

Returns an error when the backing store cannot list objects.

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

Delete an object by collection and id.

Errors

Returns an error when the backing store cannot delete the object.

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

Count total objects across all collections.

Errors

Returns an error when the backing store cannot count objects.

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

List all unique collection names.

Errors

Returns an error when the backing store cannot list collections.

Provided Methods

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

Insert or replace multiple objects in a single transaction.

This is significantly faster than calling put_object in a loop because it avoids per-object transaction overhead.

Errors

Returns an error when the backing store cannot persist any object.

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

Insert or replace an object with explicit options.

When options.index is false, the FTS search index is not updated. Use this when only metadata changes (e.g. timestamp dedup) and the body text is identical — avoids wasted FTS DELETE + INSERT.

Errors

Returns an error when the backing store cannot persist the object.

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

Delete multiple objects in a single transaction.

Returns the number of deleted objects. The SQLite adapter emits a bulk DELETE statement in one transaction. The default implementation loops calling delete_object.

Errors

Returns an error when the backing store cannot delete any object.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl ObjectStore for MemoryEngine