pub struct CheckpointManager { /* private fields */ }Expand description
Checkpoint manager that handles periodic checkpointing
Implementations§
Source§impl CheckpointManager
impl CheckpointManager
Sourcepub fn new(
store: Arc<dyn StateStore>,
config: CheckpointConfig,
) -> Result<Self, StoreError>
pub fn new( store: Arc<dyn StateStore>, config: CheckpointConfig, ) -> Result<Self, StoreError>
Create a new checkpoint manager
Sourcepub fn should_checkpoint(&self) -> bool
pub fn should_checkpoint(&self) -> bool
Check if it’s time to create a checkpoint
Sourcepub fn checkpoint(&mut self, checkpoint: Checkpoint) -> Result<(), StoreError>
pub fn checkpoint(&mut self, checkpoint: Checkpoint) -> Result<(), StoreError>
Create a checkpoint with the given state
Sourcepub fn recover(&self) -> Result<Option<Checkpoint>, StoreError>
pub fn recover(&self) -> Result<Option<Checkpoint>, StoreError>
Load the latest checkpoint for recovery
Sourcepub fn store(&self) -> &Arc<dyn StateStore>
pub fn store(&self) -> &Arc<dyn StateStore>
Get the underlying store
Trait Implementations§
Auto Trait Implementations§
impl Freeze for CheckpointManager
impl !RefUnwindSafe for CheckpointManager
impl Send for CheckpointManager
impl Sync for CheckpointManager
impl Unpin for CheckpointManager
impl UnsafeUnpin for CheckpointManager
impl !UnwindSafe for CheckpointManager
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
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more