Struct FileSystemStateStore 

pub struct FileSystemStateStore { /* private fields */ }

File system implementation of StateStore.

Stores states as JSON files organized by partition in a directory structure:

base_path/
├── 2024-01-14/
│   ├── size.json
│   ├── completeness_col1.json
│   └── mean_col2.json
└── 2024-01-15/
    └── ...

Implementations

impl FileSystemStateStore

pub fn new<P: AsRef<Path>>(base_path: P) -> AnalyzerResult<Self>

Creates a new file system state store.

Arguments

• base_path - Directory path for storing state files

Trait Implementations

impl StateStore for FileSystemStateStore

fn load_state<'life0, 'life1, 'async_trait>( &'life0 self, partition: &'life1 str, ) -> Pin<Box<dyn Future<Output = AnalyzerResult<StateMap>> + Send + 'async_trait>>

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

Loads the state for a specific partition.

fn save_state<'life0, 'life1, 'async_trait>( &'life0 self, partition: &'life1 str, state: StateMap, ) -> Pin<Box<dyn Future<Output = AnalyzerResult<()>> + Send + 'async_trait>>

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

Saves the state for a specific partition.

fn list_partitions<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = AnalyzerResult<Vec<String>>> + Send + 'async_trait>>

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

Lists all known partitions.

fn delete_partition<'life0, 'life1, 'async_trait>( &'life0 self, partition: &'life1 str, ) -> Pin<Box<dyn Future<Output = AnalyzerResult<()>> + Send + 'async_trait>>

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

Deletes the state for a specific partition.

fn load_states_batch<'life0, 'life1, 'async_trait>( &'life0 self, partitions: &'life1 [String], ) -> Pin<Box<dyn Future<Output = AnalyzerResult<HashMap<String, StateMap>>> + Send + 'async_trait>>

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

Loads states for multiple partitions.