Skip to main content

CheckpointStore

shelly_data

Trait CheckpointStore 

Source 
pub trait CheckpointStore: Send + Sync {
    // Required methods
    fn load_checkpoint(
        &self,
        pipeline_id: &str,
        tenant_id: Option<&str>,
    ) -> DataResult<Option<String>>;
    fn save_checkpoint(
        &self,
        pipeline_id: &str,
        tenant_id: Option<&str>,
        checkpoint: &str,
    ) -> DataResult<()>;
    fn clear_checkpoint(
        &self,
        pipeline_id: &str,
        tenant_id: Option<&str>,
    ) -> DataResult<()>;
}

Required Methods§

Source

fn load_checkpoint( &self, pipeline_id: &str, tenant_id: Option<&str>, ) -> DataResult<Option<String>>

Source

fn save_checkpoint( &self, pipeline_id: &str, tenant_id: Option<&str>, checkpoint: &str, ) -> DataResult<()>

Source

fn clear_checkpoint( &self, pipeline_id: &str, tenant_id: Option<&str>, ) -> DataResult<()>

Implementors§