Struct CheckpointStore

pub struct CheckpointStore { /* private fields */ }

Implementations

impl CheckpointStore

pub fn new(path: &Path) -> Arc<Self>

pub fn new_for_tests() -> Arc<Self>

pub fn new_for_db_checkpoint_handler(path: &Path) -> Arc<Self>

pub fn open_readonly(path: &Path) -> CheckpointStoreTablesReadOnly

pub fn insert_genesis_checkpoint( &self, checkpoint: VerifiedCheckpoint, contents: CheckpointContents, epoch_store: &AuthorityPerEpochStore, )

pub fn get_checkpoint_by_digest( &self, digest: &CheckpointDigest, ) -> Result<Option<VerifiedCheckpoint>, TypedStoreError>

pub fn get_checkpoint_by_sequence_number( &self, sequence_number: CheckpointSequenceNumber, ) -> Result<Option<VerifiedCheckpoint>, TypedStoreError>

pub fn get_locally_computed_checkpoint( &self, sequence_number: CheckpointSequenceNumber, ) -> Result<Option<CheckpointSummary>, TypedStoreError>

pub fn multi_get_locally_computed_checkpoints( &self, sequence_numbers: &[CheckpointSequenceNumber], ) -> Result<Vec<Option<CheckpointSummary>>, TypedStoreError>

pub fn get_sequence_number_by_contents_digest( &self, digest: &CheckpointContentsDigest, ) -> Result<Option<CheckpointSequenceNumber>, TypedStoreError>

pub fn delete_contents_digest_sequence_number_mapping( &self, digest: &CheckpointContentsDigest, ) -> Result<(), TypedStoreError>

pub fn get_latest_certified_checkpoint( &self, ) -> Result<Option<VerifiedCheckpoint>, TypedStoreError>

pub fn get_latest_locally_computed_checkpoint( &self, ) -> Result<Option<CheckpointSummary>, TypedStoreError>

pub fn multi_get_checkpoint_by_sequence_number( &self, sequence_numbers: &[CheckpointSequenceNumber], ) -> Result<Vec<Option<VerifiedCheckpoint>>, TypedStoreError>

pub fn multi_get_checkpoint_content( &self, contents_digest: &[CheckpointContentsDigest], ) -> Result<Vec<Option<CheckpointContents>>, TypedStoreError>

pub fn get_highest_verified_checkpoint( &self, ) -> Result<Option<VerifiedCheckpoint>, TypedStoreError>

pub fn get_highest_synced_checkpoint( &self, ) -> Result<Option<VerifiedCheckpoint>, TypedStoreError>

pub fn get_highest_synced_checkpoint_seq_number( &self, ) -> Result<Option<CheckpointSequenceNumber>, TypedStoreError>

pub fn get_highest_executed_checkpoint_seq_number( &self, ) -> Result<Option<CheckpointSequenceNumber>, TypedStoreError>

pub fn get_highest_executed_checkpoint( &self, ) -> Result<Option<VerifiedCheckpoint>, TypedStoreError>

pub fn get_highest_pruned_checkpoint_seq_number( &self, ) -> Result<Option<CheckpointSequenceNumber>, TypedStoreError>

pub fn get_checkpoint_contents( &self, digest: &CheckpointContentsDigest, ) -> Result<Option<CheckpointContents>, TypedStoreError>

pub fn get_full_checkpoint_contents_by_sequence_number( &self, seq: CheckpointSequenceNumber, ) -> Result<Option<FullCheckpointContents>, TypedStoreError>

pub fn insert_certified_checkpoint( &self, checkpoint: &VerifiedCheckpoint, ) -> Result<(), TypedStoreError>

pub fn insert_verified_checkpoint( &self, checkpoint: &VerifiedCheckpoint, ) -> Result<(), TypedStoreError>

pub fn update_highest_verified_checkpoint( &self, checkpoint: &VerifiedCheckpoint, ) -> Result<(), TypedStoreError>

pub fn update_highest_synced_checkpoint( &self, checkpoint: &VerifiedCheckpoint, ) -> Result<(), TypedStoreError>

pub async fn notify_read_synced_checkpoint( &self, seq: CheckpointSequenceNumber, ) -> VerifiedCheckpoint

pub async fn notify_read_executed_checkpoint( &self, seq: CheckpointSequenceNumber, ) -> VerifiedCheckpoint

pub fn update_highest_executed_checkpoint( &self, checkpoint: &VerifiedCheckpoint, ) -> Result<(), TypedStoreError>

pub fn update_highest_pruned_checkpoint( &self, checkpoint: &VerifiedCheckpoint, ) -> Result<(), TypedStoreError>

pub fn set_highest_executed_checkpoint_subtle( &self, checkpoint: &VerifiedCheckpoint, ) -> Result<(), TypedStoreError>

Sets highest executed checkpoint to any value.

WARNING: This method is very subtle and can corrupt the database if used incorrectly. It should only be used in one-off cases or tests after fully understanding the risk.

pub fn insert_checkpoint_contents( &self, contents: CheckpointContents, ) -> Result<(), TypedStoreError>

pub fn insert_verified_checkpoint_contents( &self, checkpoint: &VerifiedCheckpoint, full_contents: VerifiedCheckpointContents, ) -> Result<(), TypedStoreError>

pub fn delete_full_checkpoint_contents( &self, seq: CheckpointSequenceNumber, ) -> Result<(), TypedStoreError>

pub fn get_epoch_last_checkpoint( &self, epoch_id: EpochId, ) -> SuiResult<Option<VerifiedCheckpoint>>

pub fn get_epoch_last_checkpoint_seq_number( &self, epoch_id: EpochId, ) -> SuiResult<Option<CheckpointSequenceNumber>>

pub fn insert_epoch_last_checkpoint( &self, epoch_id: EpochId, checkpoint: &VerifiedCheckpoint, ) -> SuiResult

pub fn get_epoch_state_commitments( &self, epoch: EpochId, ) -> SuiResult<Option<Vec<CheckpointCommitment>>>

pub fn get_epoch_stats( &self, epoch: EpochId, last_checkpoint: &CheckpointSummary, ) -> Option<EpochStats>

Given the epoch ID, and the last checkpoint of the epoch, derive a few statistics of the epoch.

pub fn checkpoint_db(&self, path: &Path) -> SuiResult

pub fn delete_highest_executed_checkpoint_test_only( &self, ) -> Result<(), TypedStoreError>

pub fn reset_db_for_execution_since_genesis(&self) -> SuiResult

pub async fn reexecute_local_checkpoints( &self, state: &AuthorityState, epoch_store: &AuthorityPerEpochStore, )

TODO: this is only needed while upgrading from non-dataquarantine to dataquarantine. After that it can be deleted.

Re-executes all transactions from all local, uncertified checkpoints for crash recovery. All transactions thus re-executed are guaranteed to not have any missing dependencies, because we start from the highest executed checkpoint, and proceed through checkpoints in order.