Trait StageCheckpointWriter
pub trait StageCheckpointWriter: Send + Sync {
// Required methods
fn save_stage_checkpoint(
&self,
id: StageId,
checkpoint: StageCheckpoint,
) -> Result<(), ProviderError>;
fn save_stage_checkpoint_progress(
&self,
id: StageId,
checkpoint: Vec<u8>,
) -> Result<(), ProviderError>;
fn update_pipeline_stages(
&self,
block_number: u64,
drop_stage_checkpoint: bool,
) -> Result<(), ProviderError>;
}
Expand description
The trait for updating stage checkpoint related data.
Required Methods§
fn save_stage_checkpoint(
&self,
id: StageId,
checkpoint: StageCheckpoint,
) -> Result<(), ProviderError>
fn save_stage_checkpoint( &self, id: StageId, checkpoint: StageCheckpoint, ) -> Result<(), ProviderError>
Save stage checkpoint.
fn save_stage_checkpoint_progress(
&self,
id: StageId,
checkpoint: Vec<u8>,
) -> Result<(), ProviderError>
fn save_stage_checkpoint_progress( &self, id: StageId, checkpoint: Vec<u8>, ) -> Result<(), ProviderError>
Save stage checkpoint progress.
fn update_pipeline_stages(
&self,
block_number: u64,
drop_stage_checkpoint: bool,
) -> Result<(), ProviderError>
fn update_pipeline_stages( &self, block_number: u64, drop_stage_checkpoint: bool, ) -> Result<(), ProviderError>
Update all pipeline sync stage progress.