Trait reth_storage_api::StageCheckpointWriter

source · 
pub trait StageCheckpointWriter: Send + Sync {
    // Required methods
    fn save_stage_checkpoint(
        &self,
        id: StageId,
        checkpoint: StageCheckpoint,
    ) -> ProviderResult<()>;
    fn save_stage_checkpoint_progress(
        &self,
        id: StageId,
        checkpoint: Vec<u8>,
    ) -> ProviderResult<()>;
    fn update_pipeline_stages(
        &self,
        block_number: BlockNumber,
        drop_stage_checkpoint: bool,
    ) -> ProviderResult<()>;
}
Expand description

The trait for updating stage checkpoint related data.

Required Methods§

source

fn save_stage_checkpoint( &self, id: StageId, checkpoint: StageCheckpoint, ) -> ProviderResult<()>

Save stage checkpoint.

source

fn save_stage_checkpoint_progress( &self, id: StageId, checkpoint: Vec<u8>, ) -> ProviderResult<()>

Save stage checkpoint progress.

source

fn update_pipeline_stages( &self, block_number: BlockNumber, drop_stage_checkpoint: bool, ) -> ProviderResult<()>

Update all pipeline sync stage progress.

Implementations on Foreign Types§

source§

impl<'a, T: 'a + StageCheckpointWriter + ?Sized> StageCheckpointWriter for &'a T
where &'a T: Send + Sync,

source§

fn save_stage_checkpoint( &self, id: StageId, checkpoint: StageCheckpoint, ) -> ProviderResult<()>

source§

fn save_stage_checkpoint_progress( &self, id: StageId, checkpoint: Vec<u8>, ) -> ProviderResult<()>

source§

fn update_pipeline_stages( &self, block_number: BlockNumber, drop_stage_checkpoint: bool, ) -> ProviderResult<()>

source§

impl<T: StageCheckpointWriter + ?Sized> StageCheckpointWriter for Arc<T>
where Arc<T>: Send + Sync,

source§

fn save_stage_checkpoint( &self, id: StageId, checkpoint: StageCheckpoint, ) -> ProviderResult<()>

source§

fn save_stage_checkpoint_progress( &self, id: StageId, checkpoint: Vec<u8>, ) -> ProviderResult<()>

source§

fn update_pipeline_stages( &self, block_number: BlockNumber, drop_stage_checkpoint: bool, ) -> ProviderResult<()>

Implementors§