Struct CheckpointWriter 

pub struct CheckpointWriter { /* private fields */ }

检查点写入器

Implementations

impl CheckpointWriter

pub fn new(storage_path: impl AsRef<Path>) -> CheckpointWriter

创建新的检查点写入器

pub fn with_max_backups(self, max: usize) -> CheckpointWriter

配置最大备份数

Trait Implementations

impl CheckpointSystemTrait for CheckpointWriter

fn save<'life0, 'life1, 'async_trait>( &'life0 self, data: &'life1 CheckpointData, ) -> Pin<Box<dyn Future<Output = Result<CheckpointId, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, CheckpointWriter: 'async_trait,

保存检查点

fn load<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, checkpoint_id: Option<&'life2 CheckpointId>, ) -> Pin<Box<dyn Future<Output = Result<Option<CheckpointData>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, CheckpointWriter: 'async_trait,

加载检查点

fn list<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, ) -> Pin<Box<dyn Future<Output = Result<Vec<CheckpointMeta>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, CheckpointWriter: 'async_trait,

列出会话的所有检查点

fn delete<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, checkpoint_id: &'life2 CheckpointId, ) -> Pin<Box<dyn Future<Output = Result<bool, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, CheckpointWriter: 'async_trait,

删除检查点

fn verify(&self, path: &Path) -> Result<bool, Error>

验证检查点完整性