Struct CheckpointWriter 

pub struct CheckpointWriter { /* private fields */ }

检查点写入器

Implementations

impl CheckpointWriter

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

创建新的检查点写入器

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

配置最大备份数

Trait Implementations

impl CheckpointSystemTrait for CheckpointWriter

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

where Self: 'async_trait, 'life0: 'async_trait, 'life1: '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 = Layer2Result<Option<CheckpointData>>> + Send + 'async_trait>>

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

加载检查点

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

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

列出会话的所有检查点

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

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

删除检查点

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

验证检查点完整性