Struct ConcurrentMaplet 

pub struct ConcurrentMaplet<K, V, Op>
where
    K: Hash + Eq + Clone + Send + Sync + Debug,
    V: Clone + Send + Sync + Debug,
    Op: MergeOperator<V> + Send + Sync,
{ /* private fields */ }

Thread-safe maplet wrapper

Implementations

impl<K, V, Op> ConcurrentMaplet<K, V, Op>

where K: Hash + Eq + Clone + Send + Sync + Debug, V: Clone + PartialEq + Send + Sync + Debug, Op: MergeOperator<V> + Default + Send + Sync,

pub fn new( capacity: usize, false_positive_rate: f64, ) -> Result<ConcurrentMaplet<K, V, Op>, MapletError>

Create a new concurrent maplet

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

Insert a key-value pair (write lock)

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

Query a key (read lock)

pub async fn contains(&self, key: &K) -> bool

Check if key exists (read lock)

pub async fn delete(&self, key: &K, value: &V) -> Result<bool, MapletError>

Delete a key-value pair (write lock)

pub async fn len(&self) -> usize

Get length (read lock)

pub async fn is_empty(&self) -> bool

Check if empty (read lock)

pub async fn stats(&self) -> MapletStats

Get statistics (read lock)

Trait Implementations

impl<K, V, Op> Debug for ConcurrentMaplet<K, V, Op>

where K: Debug + Hash + Eq + Clone + Send + Sync, V: Debug + Clone + Send + Sync, Op: Debug + MergeOperator<V> + Send + Sync,

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

Formats the value using the given formatter.