Struct ConcurrentKeyspace 

pub struct ConcurrentKeyspace { /* private fields */ }

A concurrent keyspace backed by DashMap.

Provides thread-safe access to key-value data without channel overhead. All operations are lock-free for non-conflicting keys.

Implementations

impl ConcurrentKeyspace

pub fn new(max_memory: Option<usize>, eviction_policy: EvictionPolicy) -> Self

Creates a new concurrent keyspace with optional memory limit.

pub fn get(&self, key: &str) -> Option<Bytes>

Gets a value by key, returning None if not found or expired.

pub fn set(&self, key: String, value: Bytes, ttl: Option<Duration>) -> bool

Sets a key-value pair with optional TTL.

pub fn del(&self, key: &str) -> bool

Deletes a key, returning true if it existed.

pub fn exists(&self, key: &str) -> bool

Checks if a key exists (and is not expired).

pub fn random_key(&self) -> Option<String>

Returns a random non-expired key, or None if the keyspace is empty.

pub fn ttl(&self, key: &str) -> TtlResult

Returns the TTL of a key.

pub fn expire(&self, key: &str, seconds: u64) -> bool

Sets expiration on a key.

pub fn incr(&self, key: &str) -> Result<i64, ConcurrentOpError>

Increments the integer value of a key by 1. If the key doesn’t exist, it’s initialized to 0 before incrementing.

pub fn decr(&self, key: &str) -> Result<i64, ConcurrentOpError>

Decrements the integer value of a key by 1. If the key doesn’t exist, it’s initialized to 0 before decrementing.

pub fn incr_by(&self, key: &str, delta: i64) -> Result<i64, ConcurrentOpError>

Adds delta to the integer value of a key, creating it if missing. Preserves existing TTL when updating.

pub fn incr_by_float( &self, key: &str, delta: f64, ) -> Result<f64, ConcurrentFloatError>

Adds delta to the float value of a key, creating it if missing. Preserves existing TTL when updating.

pub fn append(&self, key: &str, suffix: &[u8]) -> usize

Appends a value to an existing string key, or creates a new key. Returns the new string length.

pub fn strlen(&self, key: &str) -> usize

Returns the length of the string value stored at key. Returns 0 if the key doesn’t exist.

pub fn persist(&self, key: &str) -> bool

Removes the expiration from a key. Returns true if the timeout was successfully removed.

pub fn pexpire(&self, key: &str, millis: u64) -> bool

Sets expiration in milliseconds on an existing key.

pub fn pttl(&self, key: &str) -> TtlResult

Returns the remaining TTL in milliseconds.

pub fn keys(&self, pattern: &str) -> Vec<String>

Returns all keys matching a glob pattern.

pub fn scan_keys( &self, cursor: u64, count: usize, pattern: Option<&str>, ) -> (u64, Vec<String>)

Iterates keys using a cursor. Returns (next_cursor, keys). A next_cursor of 0 means the iteration is complete.

pub fn rename(&self, key: &str, newkey: &str) -> Result<(), &'static str>

Renames a key. Returns true if the source key existed.

pub fn len(&self) -> usize

Returns the number of keys.

pub fn is_empty(&self) -> bool

Returns true if the keyspace is empty.

pub fn memory_used(&self) -> usize

Returns memory usage in bytes.

pub fn ops_count(&self) -> u64

Returns the operation count.

pub fn clear(&self)

Clears all keys.

Trait Implementations

impl Debug for ConcurrentKeyspace

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ConcurrentKeyspace

fn default() -> Self

Returns the “default value” for a type.