Struct SqliteStore 

pub struct SqliteStore { /* private fields */ }

A KVStoreSync implementation that writes to and reads from an SQLite database.

Implementations

impl SqliteStore

pub fn new( data_dir: PathBuf, db_file_name: Option<String>, kv_table_name: Option<String>, ) -> Result<Self>

Constructs a new SqliteStore.

If not already existing, a new SQLite database will be created in the given data_dir under the given db_file_name (or the default to DEFAULT_SQLITE_DB_FILE_NAME if set to None).

Similarly, the given kv_table_name will be used or default to DEFAULT_KV_TABLE_NAME.

pub fn get_data_dir(&self) -> PathBuf

Returns the data directory.

Trait Implementations

impl KVStore for SqliteStore

fn read( &self, primary_namespace: &str, secondary_namespace: &str, key: &str, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, Error>> + Send>>

Returns the data stored for the given primary_namespace, secondary_namespace, and key.

fn write( &self, primary_namespace: &str, secondary_namespace: &str, key: &str, buf: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send>>

Persists the given data under the given key.

fn remove( &self, primary_namespace: &str, secondary_namespace: &str, key: &str, _lazy: bool, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send>>

Removes any data that had previously been persisted under the given key.

fn list( &self, primary_namespace: &str, secondary_namespace: &str, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, Error>> + Send>>

Returns a list of keys that are stored under the given secondary_namespace in primary_namespace.

impl KVStoreSync for SqliteStore

fn read( &self, primary_namespace: &str, secondary_namespace: &str, key: &str, ) -> Result<Vec<u8>>

Returns the data stored for the given primary_namespace, secondary_namespace, and key.

fn write( &self, primary_namespace: &str, secondary_namespace: &str, key: &str, buf: Vec<u8>, ) -> Result<()>

Persists the given data under the given key.

fn remove( &self, primary_namespace: &str, secondary_namespace: &str, key: &str, _lazy: bool, ) -> Result<()>

Removes any data that had previously been persisted under the given key.

fn list( &self, primary_namespace: &str, secondary_namespace: &str, ) -> Result<Vec<String>>

Returns a list of keys that are stored under the given secondary_namespace in primary_namespace.