Struct KvAtomicOps 

pub struct KvAtomicOps<'a> { /* private fields */ }

Atomic KV operations interface — the seam that transports and drivers depend on.

All three verbs delegate to the runtime’s existing create_kv / get_kv / delete_kv plumbing; this struct adds the auto-create and upsert logic.

Implementations

impl<'a> KvAtomicOps<'a>

pub fn new(runtime: &'a RedDBRuntime) -> Self

pub fn set( &self, model: CollectionModel, collection: &str, key: &str, value: Value, ttl_ms: Option<u64>, if_not_exists: bool, ) -> RedDBResult<(bool, EntityId)>

Insert or update a KV entry. Auto-creates the collection when needed.

Insert or update a KV entry. Returns (created: bool, id: EntityId).

pub fn set_with_tags( &self, collection: &str, key: &str, value: Value, ttl_ms: Option<u64>, tags: &[String], if_not_exists: bool, ) -> RedDBResult<(bool, EntityId)>

pub fn set_with_tags_and_metadata( &self, collection: &str, key: &str, value: Value, ttl_ms: Option<u64>, tags: &[String], if_not_exists: bool, metadata: Vec<(String, MetadataValue)>, ) -> RedDBResult<(bool, EntityId)>

pub fn get( &self, model: CollectionModel, collection: &str, key: &str, ) -> RedDBResult<Option<Value>>

Retrieve a KV value by key. Returns None when not found.

pub fn delete( &self, model: CollectionModel, collection: &str, key: &str, ) -> RedDBResult<bool>

Delete a KV entry. Returns true if the key existed.

pub fn incr( &self, model: CollectionModel, collection: &str, key: &str, by: i64, ttl_ms: Option<u64>, ) -> RedDBResult<i64>

Atomically increment (or decrement) a counter key. Returns the new value.

• Missing key initialises at by (Redis-compat).
• Non-integer value returns an error before any mutation.

pub fn cas( &self, model: CollectionModel, collection: &str, key: &str, expected: Option<&Value>, new_value: Value, ttl_ms: Option<u64>, ) -> RedDBResult<(bool, Option<Value>)>

Compare-and-set: atomically swap key from expected to new_value.

Returns (ok, current):

• ok = true → swap applied; current is the value before the swap.
• ok = false → swap skipped; current holds the actual current value.

expected = None means the caller expects the key to be absent (create-if-absent).

pub fn invalidate_tags( &self, collection: &str, tags: &[String], ) -> RedDBResult<usize>

pub fn tags_for_key(&self, collection: &str, key: &str) -> Vec<String>