Struct CheckpointConfig
pub struct CheckpointConfig {
pub interval: Duration,
pub max_snapshots: usize,
pub storage_path: PathBuf,
pub enabled: bool,
pub name_prefix: String,
}Expand description
Configuration for periodic actor state checkpointing.
Controls how often snapshots are taken, how many are retained, and where they are stored.
Fields§
§interval: DurationInterval between periodic snapshots.
max_snapshots: usizeMaximum number of checkpoints to retain per kernel. When exceeded, the oldest checkpoint is deleted. A value of 0 means unlimited retention.
storage_path: PathBufStorage path for file-based checkpoints.
enabled: boolWhether checkpointing is enabled.
name_prefix: StringPrefix for checkpoint names (e.g., “actor_0”).
Implementations§
§impl CheckpointConfig
impl CheckpointConfig
pub fn new(interval: Duration) -> CheckpointConfig
pub fn new(interval: Duration) -> CheckpointConfig
Create a new checkpoint config with the given interval.
pub fn with_max_snapshots(self, max: usize) -> CheckpointConfig
pub fn with_max_snapshots(self, max: usize) -> CheckpointConfig
Set the maximum number of retained snapshots.
pub fn with_storage_path(self, path: impl AsRef<Path>) -> CheckpointConfig
pub fn with_storage_path(self, path: impl AsRef<Path>) -> CheckpointConfig
Set the storage path.
pub fn with_name_prefix(self, prefix: impl Into<String>) -> CheckpointConfig
pub fn with_name_prefix(self, prefix: impl Into<String>) -> CheckpointConfig
Set the name prefix for checkpoint files.
pub fn with_enabled(self, enabled: bool) -> CheckpointConfig
pub fn with_enabled(self, enabled: bool) -> CheckpointConfig
Enable or disable checkpointing.
Trait Implementations§
§impl Clone for CheckpointConfig
impl Clone for CheckpointConfig
§fn clone(&self) -> CheckpointConfig
fn clone(&self) -> CheckpointConfig
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read more§impl Debug for CheckpointConfig
impl Debug for CheckpointConfig
§impl Default for CheckpointConfig
impl Default for CheckpointConfig
§fn default() -> CheckpointConfig
fn default() -> CheckpointConfig
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for CheckpointConfig
impl RefUnwindSafe for CheckpointConfig
impl Send for CheckpointConfig
impl Sync for CheckpointConfig
impl Unpin for CheckpointConfig
impl UnwindSafe for CheckpointConfig
Blanket Implementations§
§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<F, W, T, D> Deserialize<With<T, W>, D> for F
impl<F, W, T, D> Deserialize<With<T, W>, D> for F
§fn deserialize(
&self,
deserializer: &mut D,
) -> Result<With<T, W>, <D as Fallible>::Error>
fn deserialize( &self, deserializer: &mut D, ) -> Result<With<T, W>, <D as Fallible>::Error>
Deserializes using the given deserializer
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§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§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Gets the layout of the type.