Struct FileStorage 

pub struct FileStorage { /* private fields */ }

File-based storage implementation

Implementations

impl FileStorage

pub async fn new(base_dir: impl AsRef<Path>) -> RragResult<Self>

pub async fn with_config( base_dir: impl AsRef<Path>, config: FileStorageConfig, ) -> RragResult<Self>

Trait Implementations

impl Storage for FileStorage

fn name(&self) -> &str

Storage backend name

fn put<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 StorageKey, entry: &'life2 StorageEntry, ) -> Pin<Box<dyn Future<Output = RragResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Store an entry

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 StorageKey, ) -> Pin<Box<dyn Future<Output = RragResult<Option<StorageEntry>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieve an entry

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 StorageKey, ) -> Pin<Box<dyn Future<Output = RragResult<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete an entry

fn exists<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 StorageKey, ) -> Pin<Box<dyn Future<Output = RragResult<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Check if an entry exists

fn list_keys<'life0, 'life1, 'async_trait>( &'life0 self, _query: &'life1 StorageQuery, ) -> Pin<Box<dyn Future<Output = RragResult<Vec<StorageKey>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List keys matching a query

fn get_many<'life0, 'life1, 'async_trait>( &'life0 self, keys: &'life1 [StorageKey], ) -> Pin<Box<dyn Future<Output = RragResult<Vec<(StorageKey, Option<StorageEntry>)>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Bulk get operation

fn put_many<'life0, 'life1, 'async_trait>( &'life0 self, entries: &'life1 [(StorageKey, StorageEntry)], ) -> Pin<Box<dyn Future<Output = RragResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Bulk put operation

fn delete_many<'life0, 'life1, 'async_trait>( &'life0 self, keys: &'life1 [StorageKey], ) -> Pin<Box<dyn Future<Output = RragResult<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Bulk delete operation

fn stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RragResult<StorageStats>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get storage statistics

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RragResult<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Health check

fn clear<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RragResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Clear all entries (optional)