Struct StateManager 

pub struct StateManager { /* private fields */ }

State manager for pipeline persistence

Implementations

impl StateManager

pub fn new(strategy: PersistenceStrategy, config: CheckpointConfig) -> Self

Create a new state manager

pub fn save_snapshot(&self, snapshot: StateSnapshot) -> SklResult<()>

Save a state snapshot

pub fn load_snapshot(&self, snapshot_id: &str) -> SklResult<StateSnapshot>

Load a state snapshot

pub fn create_checkpoint( &self, pipeline_id: &str, state_data: StateData, ) -> SklResult<String>

Create a checkpoint of current pipeline state

pub fn resume_from_checkpoint(&self, snapshot_id: &str) -> SklResult<StateData>

Resume from a checkpoint

pub fn list_snapshots(&self) -> Vec<String>

List available snapshots

pub fn get_version_history(&self) -> Vec<String>

Get version history

pub fn rollback(&self, target_snapshot_id: &str) -> SklResult<StateData>

Rollback to a previous version

pub fn delete_snapshot(&self, snapshot_id: &str) -> SklResult<()>

Delete a snapshot

pub fn start_auto_checkpoint( &self, pipeline_id: String, state_provider: Arc<dyn Fn() -> SklResult<StateData> + Send + Sync>, ) -> SklResult<()>

Start automatic checkpointing

pub fn stop_auto_checkpoint(&self, pipeline_id: &str) -> SklResult<()>

Stop automatic checkpointing

pub fn add_listener(&self, listener: Box<dyn Fn(&StateSnapshot) + Send + Sync>)

Add a state change listener