Struct ockam_node::storage::FileKeyValueStorage

pub struct FileKeyValueStorage<K, V> { /* private fields */ }

Key value storage backed by a file An additional cache in used to access values in memory and avoid re-reading the file too frequently WARNING: This implementation provides limited consistency if the same file is reused from multiple instances and/or processes. For example, if one process deletes a value, the other process will still have it in its cache and return it on a Get query. NOTE: Currently, unused

Implementations

impl<K: Serialize + for<'de> Deserialize<'de> + ToStringKey + Ord + Clone + Send + Sync + 'static, V: Default + Serialize + for<'de> Deserialize<'de> + Clone + Send + Sync + 'static> FileKeyValueStorage<K, V>

pub async fn create(path: &Path) -> Result<Self>

Create the file storage and in memory cache

Trait Implementations

impl<K: Serialize + for<'de> Deserialize<'de> + ToStringKey + Ord + Clone + Send + Sync + 'static, V: Clone + Serialize + for<'de> Deserialize<'de> + Send + Sync + 'static> KeyValueStorage<K, V> for FileKeyValueStorage<K, V>

fn put<'life0, 'async_trait>( &'life0 self, key: K, value: V ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Put a value in the file storage and in cache for faster access

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 K ) -> Pin<Box<dyn Future<Output = Result<Option<V>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get a value from cache. If the value is not found in the cache try to find it in the file, then cache it

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 K ) -> Pin<Box<dyn Future<Output = Result<Option<V>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete a value from the file and the cache Return the value if it was found

fn keys<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Vec<K>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Return the list of all the keys in cache