Trait ResumableRecorder

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

    // Required methods
    fn open_for_read(
        &self,
        source_key: &SourceKey<Self::HashAlgorithm>,
    ) -> Result<Box<dyn ReadOnlyResumableRecorderMedium>, Error>;
    fn open_for_append(
        &self,
        source_key: &SourceKey<Self::HashAlgorithm>,
    ) -> Result<Box<dyn AppendOnlyResumableRecorderMedium>, Error>;
    fn open_for_create_new(
        &self,
        source_key: &SourceKey<Self::HashAlgorithm>,
    ) -> Result<Box<dyn AppendOnlyResumableRecorderMedium>, Error>;
    fn delete(
        &self,
        source_key: &SourceKey<Self::HashAlgorithm>,
    ) -> Result<(), Error>;
    fn open_for_async_read<'a>(
        &'a self,
        source_key: &'a SourceKey<Self::HashAlgorithm>,
    ) -> Pin<Box<dyn Future<Output = Result<Box<dyn ReadOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>;
    fn open_for_async_append<'a>(
        &'a self,
        source_key: &'a SourceKey<Self::HashAlgorithm>,
    ) -> Pin<Box<dyn Future<Output = Result<Box<dyn AppendOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>;
    fn open_for_async_create_new<'a>(
        &'a self,
        source_key: &'a SourceKey<Self::HashAlgorithm>,
    ) -> Pin<Box<dyn Future<Output = Result<Box<dyn AppendOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>;
    fn async_delete<'a>(
        &'a self,
        source_key: &'a SourceKey<Self::HashAlgorithm>,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'a>>;
}

断点恢复记录器

Required Associated Types

type HashAlgorithm: Digest

数据源 KEY 的哈希算法

Required Methods

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

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

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

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

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

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

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

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

fn open_for_async_read<'a>( &'a self, source_key: &'a SourceKey<Self::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn ReadOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>

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

fn open_for_async_append<'a>( &'a self, source_key: &'a SourceKey<Self::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn AppendOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>

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

fn open_for_async_create_new<'a>( &'a self, source_key: &'a SourceKey<Self::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn AppendOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>

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

fn async_delete<'a>( &'a self, source_key: &'a SourceKey<Self::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'a>>

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

Implementations on Foreign Types

impl<'b, T> ResumableRecorder for &'b T

where T: 'b + ResumableRecorder + ?Sized, &'b T: DynClone + Debug + Sync + Send,

type HashAlgorithm = <T as ResumableRecorder>::HashAlgorithm

fn open_for_read( &self, source_key: &SourceKey<<&'b T as ResumableRecorder>::HashAlgorithm>, ) -> Result<Box<dyn ReadOnlyResumableRecorderMedium>, Error>

fn open_for_append( &self, source_key: &SourceKey<<&'b T as ResumableRecorder>::HashAlgorithm>, ) -> Result<Box<dyn AppendOnlyResumableRecorderMedium>, Error>

fn open_for_create_new( &self, source_key: &SourceKey<<&'b T as ResumableRecorder>::HashAlgorithm>, ) -> Result<Box<dyn AppendOnlyResumableRecorderMedium>, Error>

fn delete( &self, source_key: &SourceKey<<&'b T as ResumableRecorder>::HashAlgorithm>, ) -> Result<(), Error>

fn open_for_async_read<'a>( &'a self, source_key: &'a SourceKey<<&'b T as ResumableRecorder>::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn ReadOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>

fn open_for_async_append<'a>( &'a self, source_key: &'a SourceKey<<&'b T as ResumableRecorder>::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn AppendOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>

fn open_for_async_create_new<'a>( &'a self, source_key: &'a SourceKey<<&'b T as ResumableRecorder>::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn AppendOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>

fn async_delete<'a>( &'a self, source_key: &'a SourceKey<<&'b T as ResumableRecorder>::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'a>>

impl<'b, T> ResumableRecorder for &'b mut T

where T: 'b + ResumableRecorder + ?Sized, &'b mut T: DynClone + Debug + Sync + Send,

type HashAlgorithm = <T as ResumableRecorder>::HashAlgorithm

fn open_for_read( &self, source_key: &SourceKey<<&'b mut T as ResumableRecorder>::HashAlgorithm>, ) -> Result<Box<dyn ReadOnlyResumableRecorderMedium>, Error>

fn open_for_append( &self, source_key: &SourceKey<<&'b mut T as ResumableRecorder>::HashAlgorithm>, ) -> Result<Box<dyn AppendOnlyResumableRecorderMedium>, Error>

fn open_for_create_new( &self, source_key: &SourceKey<<&'b mut T as ResumableRecorder>::HashAlgorithm>, ) -> Result<Box<dyn AppendOnlyResumableRecorderMedium>, Error>

fn delete( &self, source_key: &SourceKey<<&'b mut T as ResumableRecorder>::HashAlgorithm>, ) -> Result<(), Error>

fn open_for_async_read<'a>( &'a self, source_key: &'a SourceKey<<&'b mut T as ResumableRecorder>::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn ReadOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>

fn open_for_async_append<'a>( &'a self, source_key: &'a SourceKey<<&'b mut T as ResumableRecorder>::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn AppendOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>

fn open_for_async_create_new<'a>( &'a self, source_key: &'a SourceKey<<&'b mut T as ResumableRecorder>::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn AppendOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>

fn async_delete<'a>( &'a self, source_key: &'a SourceKey<<&'b mut T as ResumableRecorder>::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'a>>

impl<T> ResumableRecorder for Box<T>

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

type HashAlgorithm = <T as ResumableRecorder>::HashAlgorithm

fn open_for_read( &self, source_key: &SourceKey<<Box<T> as ResumableRecorder>::HashAlgorithm>, ) -> Result<Box<dyn ReadOnlyResumableRecorderMedium>, Error>

fn open_for_append( &self, source_key: &SourceKey<<Box<T> as ResumableRecorder>::HashAlgorithm>, ) -> Result<Box<dyn AppendOnlyResumableRecorderMedium>, Error>

fn open_for_create_new( &self, source_key: &SourceKey<<Box<T> as ResumableRecorder>::HashAlgorithm>, ) -> Result<Box<dyn AppendOnlyResumableRecorderMedium>, Error>

fn delete( &self, source_key: &SourceKey<<Box<T> as ResumableRecorder>::HashAlgorithm>, ) -> Result<(), Error>

fn open_for_async_read<'a>( &'a self, source_key: &'a SourceKey<<Box<T> as ResumableRecorder>::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn ReadOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>

fn open_for_async_append<'a>( &'a self, source_key: &'a SourceKey<<Box<T> as ResumableRecorder>::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn AppendOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>

fn open_for_async_create_new<'a>( &'a self, source_key: &'a SourceKey<<Box<T> as ResumableRecorder>::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn AppendOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>

fn async_delete<'a>( &'a self, source_key: &'a SourceKey<<Box<T> as ResumableRecorder>::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'a>>

impl<T> ResumableRecorder for Rc<T>

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

type HashAlgorithm = <T as ResumableRecorder>::HashAlgorithm

fn open_for_read( &self, source_key: &SourceKey<<Rc<T> as ResumableRecorder>::HashAlgorithm>, ) -> Result<Box<dyn ReadOnlyResumableRecorderMedium>, Error>

fn open_for_append( &self, source_key: &SourceKey<<Rc<T> as ResumableRecorder>::HashAlgorithm>, ) -> Result<Box<dyn AppendOnlyResumableRecorderMedium>, Error>

fn open_for_create_new( &self, source_key: &SourceKey<<Rc<T> as ResumableRecorder>::HashAlgorithm>, ) -> Result<Box<dyn AppendOnlyResumableRecorderMedium>, Error>

fn delete( &self, source_key: &SourceKey<<Rc<T> as ResumableRecorder>::HashAlgorithm>, ) -> Result<(), Error>

fn open_for_async_read<'a>( &'a self, source_key: &'a SourceKey<<Rc<T> as ResumableRecorder>::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn ReadOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>

fn open_for_async_append<'a>( &'a self, source_key: &'a SourceKey<<Rc<T> as ResumableRecorder>::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn AppendOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>

fn open_for_async_create_new<'a>( &'a self, source_key: &'a SourceKey<<Rc<T> as ResumableRecorder>::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn AppendOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>

fn async_delete<'a>( &'a self, source_key: &'a SourceKey<<Rc<T> as ResumableRecorder>::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'a>>

impl<T> ResumableRecorder for Arc<T>

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

type HashAlgorithm = <T as ResumableRecorder>::HashAlgorithm

fn open_for_read( &self, source_key: &SourceKey<<Arc<T> as ResumableRecorder>::HashAlgorithm>, ) -> Result<Box<dyn ReadOnlyResumableRecorderMedium>, Error>

fn open_for_append( &self, source_key: &SourceKey<<Arc<T> as ResumableRecorder>::HashAlgorithm>, ) -> Result<Box<dyn AppendOnlyResumableRecorderMedium>, Error>

fn open_for_create_new( &self, source_key: &SourceKey<<Arc<T> as ResumableRecorder>::HashAlgorithm>, ) -> Result<Box<dyn AppendOnlyResumableRecorderMedium>, Error>

fn delete( &self, source_key: &SourceKey<<Arc<T> as ResumableRecorder>::HashAlgorithm>, ) -> Result<(), Error>

fn open_for_async_read<'a>( &'a self, source_key: &'a SourceKey<<Arc<T> as ResumableRecorder>::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn ReadOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>

fn open_for_async_append<'a>( &'a self, source_key: &'a SourceKey<<Arc<T> as ResumableRecorder>::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn AppendOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>

fn open_for_async_create_new<'a>( &'a self, source_key: &'a SourceKey<<Arc<T> as ResumableRecorder>::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn AppendOnlyAsyncResumableRecorderMedium>, Error>> + Send + 'a>>

fn async_delete<'a>( &'a self, source_key: &'a SourceKey<<Arc<T> as ResumableRecorder>::HashAlgorithm>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'a>>

Implementors

impl<O> ResumableRecorder for DummyResumableRecorder<O>

where O: Clone + Digest + Send + Sync + Unpin,

type HashAlgorithm = O

impl<O> ResumableRecorder for FileSystemResumableRecorder<O>

where O: Digest,

type HashAlgorithm = O