Struct AsyncRocksDB 

pub struct AsyncRocksDB { /* private fields */ }

Async RocksDB wrapper.

Implementations

impl AsyncRocksDB

pub async fn open_default<P: AsRef<Path>>( path: P, ) -> Result<Self, AsyncRocksError>

pub fn snapshot(&self) -> Snapshot

pub async fn put<K, V>( &self, key: K, value: V, cf: Option<&str>, ) -> Result<(), AsyncRocksError>

where K: AsRef<[u8]> + Send + 'static, V: AsRef<[u8]> + Send + 'static,

pub async fn get<K>( &self, key: K, cf: Option<&str>, snapshot: Option<Snapshot>, ) -> Result<Option<Vec<u8>>, AsyncRocksError>

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

pub async fn delete<K>( &self, key: K, cf: Option<&str>, ) -> Result<(), AsyncRocksError>

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

pub async fn multi_get<K>( &self, keys: Vec<K>, cf: Option<&str>, snapshot: Option<Snapshot>, ) -> Result<Vec<Option<Vec<u8>>>, AsyncRocksError>

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

pub async fn multi_delete<K>( &self, keys: Vec<K>, cf: Option<&str>, ) -> Result<(), AsyncRocksError>

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

pub async fn flush(&self) -> Result<(), AsyncRocksError>

pub async fn compact_range<K: AsRef<[u8]>>( &self, start: Option<K>, end: Option<K>, cf: Option<&str>, ) -> Result<(), AsyncRocksError>

pub async fn all( &self, cf: Option<&str>, snapshot: Option<Snapshot>, ) -> Result<Vec<(Vec<u8>, Vec<u8>)>, AsyncRocksError>

pub async fn prefix_all<P>( &self, prefix: P, cf: Option<&str>, snapshot: Option<Snapshot>, ) -> Result<Vec<(Vec<u8>, Vec<u8>)>, AsyncRocksError>

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