Struct Store

pub struct Store<K, V> {
    pub rocksdb: Arc<DBWithThreadMode<MultiThreaded>>,
    /* private fields */
}

Fields

rocksdb: Arc<DBWithThreadMode<MultiThreaded>>

Implementations

impl<Key, Value> Store<Key, Value>

where Key: Hash + Eq + Serialize + DeserializeOwned + Send + 'static, Value: Serialize + DeserializeOwned + Send + Clone + 'static,

pub fn new(keyed_db: DBMap<Key, Value>) -> Self

impl<Key, Value> Store<Key, Value>

where Key: Serialize + DeserializeOwned + Send, Value: Serialize + DeserializeOwned + Send,

pub async fn async_write(&self, key: Key, value: Value)

pub async fn sync_write(&self, key: Key, value: Value) -> Result<(), StoreError>

pub async fn sync_write_all( &self, key_value_pairs: impl IntoIterator<Item = (Key, Value)>, ) -> Result<(), StoreError>

Atomically writes all the key-value pairs in storage. If the operation is successful, then the result will be a non error empty result. Otherwise the error is returned.

pub async fn remove(&self, key: Key)

pub async fn remove_all( &self, keys: impl IntoIterator<Item = Key>, ) -> Result<(), StoreError>

Atomically removes all the data referenced by the provided keys. If the operation is successful, then the result will be a non error empty result. Otherwise the error is returned.

pub async fn read_raw_bytes( &self, key: Key, ) -> Result<Option<Vec<u8>>, StoreError>

Returns the read value in raw bincode bytes

pub async fn read(&self, key: Key) -> Result<Option<Value>, StoreError>

pub async fn read_all( &self, keys: impl IntoIterator<Item = Key>, ) -> Result<Vec<Option<Value>>, StoreError>

Fetches all the values for the provided keys.

pub async fn notify_read(&self, key: Key) -> Result<Option<Value>, StoreError>

pub async fn iter( &self, predicate: Option<Box<dyn Fn(&(Key, Value)) -> bool + Send>>, ) -> HashMap<Key, Value>

Trait Implementations

impl<K: Clone, V: Clone> Clone for Store<K, V>

fn clone(&self) -> Store<K, V>

Returns a copy of the value.

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

Performs copy-assignment from source.