Struct DebouncedFileStorage 

pub struct DebouncedFileStorage { /* private fields */ }

Implementations

impl DebouncedFileStorage

pub fn new(base_path: PathBuf, flush_interval_ms: u64) -> StorageResult<Self>

pub fn flush(&self) -> StorageResult<()>

Trait Implementations

impl StorageAdapter for DebouncedFileStorage

fn get(&self, key: &str) -> StorageResult<Option<String>>

fn put(&self, key: &str, value: String) -> StorageResult<()>

fn put_preserved(&self, key: &str, value: String) -> StorageResult<()>

Preserve a migration input before a later checkpoint can replace it. Buffered adapters must commit this write before returning success.

fn del(&self, key: &str) -> StorageResult<()>

fn list(&self, prefix: &str) -> StorageResult<Vec<String>>

fn put_checkpoint( &self, key: &str, value: &StorageCheckpoint, ) -> StorageResult<()>