Enum DefaultStorageDB

pub enum DefaultStorageDB {
    Sled(SledStorageDB),
    Redis(RedisStorageDB),
    RedisCluster(RedisStorageDB),
}

Unified storage backend enum (dispatches to concrete implementations)

Variants

Sled(SledStorageDB)

Sled database backend

Redis(RedisStorageDB)

Redis backend

RedisCluster(RedisStorageDB)

Redis Cluster backend

Implementations

impl DefaultStorageDB

pub async fn map<V: AsRef<[u8]> + Sync + Send>( &self, name: V, expire: Option<i64>, ) -> Result<StorageMap>

Accesses a named map

pub async fn map_remove<K>(&self, name: K) -> Result<()>

where K: AsRef<[u8]> + Sync + Send,

Removes a named map

pub async fn map_contains_key<K: AsRef<[u8]> + Sync + Send>( &self, key: K, ) -> Result<bool>

Checks if map exists

pub async fn list<V: AsRef<[u8]> + Sync + Send>( &self, name: V, expire: Option<i64>, ) -> Result<StorageList>

Accesses a named list

pub async fn list_remove<K>(&self, name: K) -> Result<()>

where K: AsRef<[u8]> + Sync + Send,

Removes a named list

pub async fn list_contains_key<K: AsRef<[u8]> + Sync + Send>( &self, key: K, ) -> Result<bool>

Checks if list exists

pub async fn insert<K, V>(&self, key: K, val: &V) -> Result<()>

where K: AsRef<[u8]> + Sync + Send, V: Serialize + Sync + Send,

Inserts a key-value pair

pub async fn get<K, V>(&self, key: K) -> Result<Option<V>>

where K: AsRef<[u8]> + Sync + Send, V: DeserializeOwned + Sync + Send,

Retrieves a value by key

pub async fn remove<K>(&self, key: K) -> Result<()>

where K: AsRef<[u8]> + Sync + Send,

Removes a key-value pair

pub async fn batch_insert<V>(&self, key_vals: Vec<(Vec<u8>, V)>) -> Result<()>

where V: Serialize + Sync + Send,

Batch insert of key-value pairs

pub async fn batch_remove(&self, keys: Vec<Vec<u8>>) -> Result<()>

Batch removal of keys

pub async fn counter_incr<K>(&self, key: K, increment: isize) -> Result<()>

where K: AsRef<[u8]> + Sync + Send,

Increments a counter

pub async fn counter_decr<K>(&self, key: K, decrement: isize) -> Result<()>

where K: AsRef<[u8]> + Sync + Send,

Decrements a counter

pub async fn counter_get<K>(&self, key: K) -> Result<Option<isize>>

where K: AsRef<[u8]> + Sync + Send,

Gets counter value

pub async fn counter_set<K>(&self, key: K, val: isize) -> Result<()>

where K: AsRef<[u8]> + Sync + Send,

Sets counter value

pub async fn len(&self) -> Result<usize>

Gets number of items (requires “len” feature)

pub async fn db_size(&self) -> Result<usize>

Gets total storage size in bytes

pub async fn contains_key<K: AsRef<[u8]> + Sync + Send>( &self, key: K, ) -> Result<bool>

Checks if key exists

pub async fn expire_at<K>(&self, key: K, at: i64) -> Result<bool>

where K: AsRef<[u8]> + Sync + Send,

Sets expiration timestamp (requires “ttl” feature)

pub async fn expire<K>(&self, key: K, dur: i64) -> Result<bool>

where K: AsRef<[u8]> + Sync + Send,

Sets expiration duration (requires “ttl” feature)

pub async fn ttl<K>(&self, key: K) -> Result<Option<i64>>

where K: AsRef<[u8]> + Sync + Send,

Gets time-to-live (requires “ttl” feature)

pub async fn map_iter<'a>( &'a mut self, ) -> Result<Box<dyn AsyncIterator<Item = Result<StorageMap>> + Send + 'a>>

Iterates over maps

pub async fn list_iter<'a>( &'a mut self, ) -> Result<Box<dyn AsyncIterator<Item = Result<StorageList>> + Send + 'a>>

Iterates over lists

pub async fn scan<'a, P>( &'a mut self, pattern: P, ) -> Result<Box<dyn AsyncIterator<Item = Result<Vec<u8>>> + Send + 'a>>

where P: AsRef<[u8]> + Send + Sync,

Scans keys matching pattern

pub async fn info(&self) -> Result<Value>

Gets storage information

Trait Implementations

impl Clone for DefaultStorageDB

fn clone(&self) -> DefaultStorageDB

Returns a duplicate of the value.

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.