Skip to main content

CheckpointStorageEnv

prodigy::cook::execution::mapreduce::checkpoint::effects::storage

Trait CheckpointStorageEnv 

Source 
pub trait CheckpointStorageEnv:
    Clone
    + Send
    + Sync {
    // Required methods
    fn storage(&self) -> Arc<dyn CheckpointStorage> ⓘ;
    fn current_checkpoint(&self) -> Arc<RwLock<Option<MapReduceCheckpoint>>> ⓘ;
    fn storage_path(&self) -> PathBuf;
}
Expand description

Environment for checkpoint storage effects

Required Methods§

Source

fn storage(&self) -> Arc<dyn CheckpointStorage> ⓘ

Get the checkpoint storage implementation

Source

fn current_checkpoint(&self) -> Arc<RwLock<Option<MapReduceCheckpoint>>> ⓘ

Get the current checkpoint state

Source

fn storage_path(&self) -> PathBuf

Get the storage path for checkpoints

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§