Struct FilesystemStore 

pub struct FilesystemStore { /* private fields */ }

A KVStore and KVStoreSync implementation that writes to and reads from the file system.

Implementations

impl FilesystemStore

pub fn new(data_dir: PathBuf) -> Self

Constructs a new FilesystemStore.

pub fn get_data_dir(&self) -> PathBuf

Returns the data directory.

Trait Implementations

impl KVStore for FilesystemStore

Available on crate feature tokio only.

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

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 + 'static>>

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 + 'static>>

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 + 'static>>

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

impl KVStoreSync for FilesystemStore

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

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<(), Error>

Persists the given data under the given key.

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

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

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

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

impl MigratableKVStore for FilesystemStore

fn list_all_keys(&self) -> Result<Vec<(String, String, String)>, Error>

Returns all known keys as a list of primary_namespace, secondary_namespace, key tuples.