Struct qiniu_upload_manager::FileSystemResumableRecorder

pub struct FileSystemResumableRecorder<O = Sha1> { /* private fields */ }

文件系统断点恢复记录器

基于文件系统提供断点恢复记录功能

Implementations

impl<O> FileSystemResumableRecorder<O>

pub fn new(path: impl Into<PathBuf>) -> Self

创建文件系统断点恢复记录器，传入一个目录路径用于储存断点记录

Examples found in repository

src/resumable_recorder/file.rs (line 155)

    fn default() -> Self {
        Self::new(temp_dir().join(DEFAULT_DIRECTORY_NAME))
    }

Trait Implementations

impl<O> Clone for FileSystemResumableRecorder<O>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<O> Debug for FileSystemResumableRecorder<O>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<O> Default for FileSystemResumableRecorder<O>

fn default() -> Self

Returns the “default value” for a type.

impl<O: Digest> ResumableRecorder for FileSystemResumableRecorder<O>

type HashAlgorithm = O

数据源 KEY 的哈希算法

fn open_for_read(
    &self,
    source_key: &SourceKey<Self::HashAlgorithm>
) -> IoResult<Box<dyn ReadOnlyResumableRecorderMedium>>

根据数据源 KEY 打开只读记录介质

fn open_for_append(
    &self,
    source_key: &SourceKey<Self::HashAlgorithm>
) -> IoResult<Box<dyn AppendOnlyResumableRecorderMedium>>

根据数据源 KEY 打开追加记录介质

fn open_for_create_new(
    &self,
    source_key: &SourceKey<Self::HashAlgorithm>
) -> IoResult<Box<dyn AppendOnlyResumableRecorderMedium>>

根据数据源 KEY 创建追加记录介质

fn delete(&self, source_key: &SourceKey<Self::HashAlgorithm>) -> IoResult<()>

根据数据源 KEY 删除记录介质

fn open_for_async_read<'a>(
    &'a self,
    source_key: &'a SourceKey<Self::HashAlgorithm>
) -> BoxFuture<'a, IoResult<Box<dyn ReadOnlyAsyncResumableRecorderMedium>>>

Available on crate feature async only.

根据数据源 KEY 打开异步只读记录介质

fn open_for_async_append<'a>(
    &'a self,
    source_key: &'a SourceKey<Self::HashAlgorithm>
) -> BoxFuture<'a, IoResult<Box<dyn AppendOnlyAsyncResumableRecorderMedium>>>

Available on crate feature async only.

根据数据源 KEY 打开异步追加记录介质

fn open_for_async_create_new<'a>(
    &'a self,
    source_key: &'a SourceKey<Self::HashAlgorithm>
) -> BoxFuture<'a, IoResult<Box<dyn AppendOnlyAsyncResumableRecorderMedium>>>

Available on crate feature async only.

根据数据源 KEY 创建异步追加记录介质

fn async_delete<'a>(
    &'a self,
    source_key: &'a SourceKey<Self::HashAlgorithm>
) -> BoxFuture<'a, IoResult<()>>

Available on crate feature async only.

根据数据源 KEY 异步删除记录介质

impl<O> Send for FileSystemResumableRecorder<O>

impl<O> Sync for FileSystemResumableRecorder<O>