Trait qiniu_upload_manager::prelude::ResumableRecorder

pub trait ResumableRecorder: DynClone + Debug + Sync + Send {
    type HashAlgorithm: Digest;

    fn open_for_read(
        &self,
        source_key: &SourceKey<Self::HashAlgorithm>
    ) -> IoResult<Box<dyn ReadOnlyResumableRecorderMedium>>;
    fn open_for_append(
        &self,
        source_key: &SourceKey<Self::HashAlgorithm>
    ) -> IoResult<Box<dyn AppendOnlyResumableRecorderMedium>>;
    fn open_for_create_new(
        &self,
        source_key: &SourceKey<Self::HashAlgorithm>
    ) -> IoResult<Box<dyn AppendOnlyResumableRecorderMedium>>;
    fn delete(&self, source_key: &SourceKey<Self::HashAlgorithm>) -> IoResult<()>;
    fn open_for_async_read<'a>(
        &'a self,
        source_key: &'a SourceKey<Self::HashAlgorithm>
    ) -> BoxFuture<'a, IoResult<Box<dyn ReadOnlyAsyncResumableRecorderMedium>>>;
    fn open_for_async_append<'a>(
        &'a self,
        source_key: &'a SourceKey<Self::HashAlgorithm>
    ) -> BoxFuture<'a, IoResult<Box<dyn AppendOnlyAsyncResumableRecorderMedium>>>;
    fn open_for_async_create_new<'a>(
        &'a self,
        source_key: &'a SourceKey<Self::HashAlgorithm>
    ) -> BoxFuture<'a, IoResult<Box<dyn AppendOnlyAsyncResumableRecorderMedium>>>;
    fn async_delete<'a>(
        &'a self,
        source_key: &'a SourceKey<Self::HashAlgorithm>
    ) -> BoxFuture<'a, IoResult<()>>;
}

断点恢复记录器

Required Associated Types

type HashAlgorithm: Digest

数据源 KEY 的哈希算法

Required Methods

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 异步删除记录介质

Trait Implementations

impl<'clone, H> Clone for Box<dyn ResumableRecorder<HashAlgorithm = H> + 'clone>where
    H: Digest,

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'clone, H> Clone for Box<dyn ResumableRecorder<HashAlgorithm = H> + Send + 'clone>where
    H: Digest,

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'clone, H> Clone for Box<dyn ResumableRecorder<HashAlgorithm = H> + Send + Sync + 'clone>where
    H: Digest,

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'clone, H> Clone for Box<dyn ResumableRecorder<HashAlgorithm = H> + Sync + 'clone>where
    H: Digest,

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

Implementations on Foreign Types

impl<'b, T: 'b + ResumableRecorder + ?Sized> ResumableRecorder for &'b Twhere
    &'b T: DynClone + Debug + Sync + Send,

type HashAlgorithm = <T as ResumableRecorder>::HashAlgorithm

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

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

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

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

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.

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.

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.

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

Available on crate feature async only.

impl<'b, T: 'b + ResumableRecorder + ?Sized> ResumableRecorder for &'b mut Twhere
    &'b mut T: DynClone + Debug + Sync + Send,

type HashAlgorithm = <T as ResumableRecorder>::HashAlgorithm

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

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

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

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

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.

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.

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.

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

Available on crate feature async only.

impl<T: ResumableRecorder + ?Sized> ResumableRecorder for Box<T>where
    Box<T>: DynClone + Debug + Sync + Send,

type HashAlgorithm = <T as ResumableRecorder>::HashAlgorithm

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

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

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

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

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.

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.

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.

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

Available on crate feature async only.

impl<T: ResumableRecorder + ?Sized> ResumableRecorder for Rc<T>where
    Rc<T>: DynClone + Debug + Sync + Send,

type HashAlgorithm = <T as ResumableRecorder>::HashAlgorithm

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

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

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

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

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.

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.

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.

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

Available on crate feature async only.

impl<T: ResumableRecorder + ?Sized> ResumableRecorder for Arc<T>where
    Arc<T>: DynClone + Debug + Sync + Send,

type HashAlgorithm = <T as ResumableRecorder>::HashAlgorithm

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

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

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

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

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.

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.

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.

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

Available on crate feature async only.

Implementors

impl<O: Clone + Digest + Send + Sync + Unpin> ResumableRecorder for DummyResumableRecorder<O>

type HashAlgorithm = O

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

type HashAlgorithm = O