pub struct CheckpointConsistencyValidator { /* private fields */ }Expand description
Checkpoint consistency validator
Implementations§
Source§impl CheckpointConsistencyValidator
impl CheckpointConsistencyValidator
Sourcepub fn new(config: V2WALConfig) -> Self
pub fn new(config: V2WALConfig) -> Self
Create a new checkpoint consistency validator
Sourcepub fn validate_checkpoint_consistency(
&self,
checkpoint_lsn_range: (u64, u64),
last_checkpointed_lsn: u64,
) -> ConsistencyResult
pub fn validate_checkpoint_consistency( &self, checkpoint_lsn_range: (u64, u64), last_checkpointed_lsn: u64, ) -> ConsistencyResult
Validate checkpoint consistency with WAL state
Sourcepub fn validate_dirty_block_consistency(
&self,
dirty_blocks: &DirtyBlockTracker,
max_pending_blocks: u64,
) -> ConsistencyResult
pub fn validate_dirty_block_consistency( &self, dirty_blocks: &DirtyBlockTracker, max_pending_blocks: u64, ) -> ConsistencyResult
Validate dirty block state consistency
Sourcepub fn validate_progress_consistency(
&self,
progress: &CheckpointProgress,
checkpoint_duration: Duration,
) -> ConsistencyResult
pub fn validate_progress_consistency( &self, progress: &CheckpointProgress, checkpoint_duration: Duration, ) -> ConsistencyResult
Validate checkpoint progress consistency
Sourcepub fn validate_checkpoint_wal_consistency(
&self,
checkpoint_size: u64,
wal_size: u64,
) -> ConsistencyResult
pub fn validate_checkpoint_wal_consistency( &self, checkpoint_size: u64, wal_size: u64, ) -> ConsistencyResult
Validate checkpoint-WAL size consistency
Sourcepub fn validate_comprehensive_consistency(
&self,
dirty_blocks: &DirtyBlockTracker,
checkpoint_progress: &CheckpointProgress,
checkpoint_lsn_range: (u64, u64),
last_checkpointed_lsn: u64,
checkpoint_duration: Duration,
max_pending_blocks: u64,
) -> ConsistencyResult
pub fn validate_comprehensive_consistency( &self, dirty_blocks: &DirtyBlockTracker, checkpoint_progress: &CheckpointProgress, checkpoint_lsn_range: (u64, u64), last_checkpointed_lsn: u64, checkpoint_duration: Duration, max_pending_blocks: u64, ) -> ConsistencyResult
Perform comprehensive consistency validation
Auto Trait Implementations§
impl Freeze for CheckpointConsistencyValidator
impl RefUnwindSafe for CheckpointConsistencyValidator
impl Send for CheckpointConsistencyValidator
impl Sync for CheckpointConsistencyValidator
impl Unpin for CheckpointConsistencyValidator
impl UnwindSafe for CheckpointConsistencyValidator
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more