Struct FileSnapshotStore 

pub struct FileSnapshotStore { /* private fields */ }

Writes each snapshot to one file under a directory.

A save writes a temporary file in the same directory and renames it over the target, so a crash in the middle of a save leaves the previous snapshot whole. The directory is created on the first save. The store needs a file system and a blocking thread pool, so it exists only on native targets.

Examples

use krabka_client_streams::store::snapshot::{FileSnapshotStore, SnapshotKey};

let store = FileSnapshotStore::new(std::env::temp_dir().join("krabka-snapshots"));
// transactions-0-1-epoch-7.snapshot
let file = store.file(&SnapshotKey::new("0-1", "transactions", 7));

Implementations

impl FileSnapshotStore

pub fn new(directory: impl Into<PathBuf>) -> Self

Creates a store rooted at directory.

pub fn file(&self, key: &SnapshotKey) -> PathBuf

The file that holds one key’s snapshot.

Trait Implementations

impl Clone for FileSnapshotStore

fn clone(&self) -> FileSnapshotStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for FileSnapshotStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl SnapshotStore for FileSnapshotStore

fn save<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 SnapshotKey, snapshot: &'life2 TaskSnapshot, ) -> Pin<Box<dyn Future<Output = Result<(), StreamsClientError>> + Send + 'async_trait>>

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

Stores one task’s snapshot under key, and replaces what was there.

fn load<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 SnapshotKey, ) -> Pin<Box<dyn Future<Output = Result<Option<TaskSnapshot>, StreamsClientError>> + Send + 'async_trait>>

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

Reads back the snapshot stored under key, or None when there is none.