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 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 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.