Trait qiniu_sdk::prelude::ResumableRecorder
source · pub trait ResumableRecorder: DynClone + Debug + Sync + Send {
type HashAlgorithm: Digest;
fn open_for_read(
&self,
source_key: &SourceKey<Self::HashAlgorithm>
) -> Result<Box<dyn ReadOnlyResumableRecorderMedium + 'static, Global>, Error>;
fn open_for_append(
&self,
source_key: &SourceKey<Self::HashAlgorithm>
) -> Result<Box<dyn AppendOnlyResumableRecorderMedium + 'static, Global>, Error>;
fn open_for_create_new(
&self,
source_key: &SourceKey<Self::HashAlgorithm>
) -> Result<Box<dyn AppendOnlyResumableRecorderMedium + 'static, Global>, Error>;
fn delete(
&self,
source_key: &SourceKey<Self::HashAlgorithm>
) -> Result<(), Error>;
fn open_for_async_read(
&'a self,
source_key: &'a SourceKey<Self::HashAlgorithm>
) -> Pin<Box<dyn Future<Output = Result<Box<dyn ReadOnlyAsyncResumableRecorderMedium + 'static, Global>, Error>> + Send + 'a, Global>>;
fn open_for_async_append(
&'a self,
source_key: &'a SourceKey<Self::HashAlgorithm>
) -> Pin<Box<dyn Future<Output = Result<Box<dyn AppendOnlyAsyncResumableRecorderMedium + 'static, Global>, Error>> + Send + 'a, Global>>;
fn open_for_async_create_new(
&'a self,
source_key: &'a SourceKey<Self::HashAlgorithm>
) -> Pin<Box<dyn Future<Output = Result<Box<dyn AppendOnlyAsyncResumableRecorderMedium + 'static, Global>, Error>> + Send + 'a, Global>>;
fn async_delete(
&'a self,
source_key: &'a SourceKey<Self::HashAlgorithm>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'a, Global>>;
}
Expand description
断点恢复记录器
Required Associated Types
sourcetype HashAlgorithm: Digest
type HashAlgorithm: Digest
数据源 KEY 的哈希算法
Required Methods
sourcefn open_for_read(
&self,
source_key: &SourceKey<Self::HashAlgorithm>
) -> Result<Box<dyn ReadOnlyResumableRecorderMedium + 'static, Global>, Error>
fn open_for_read(
&self,
source_key: &SourceKey<Self::HashAlgorithm>
) -> Result<Box<dyn ReadOnlyResumableRecorderMedium + 'static, Global>, Error>
根据数据源 KEY 打开只读记录介质
sourcefn open_for_append(
&self,
source_key: &SourceKey<Self::HashAlgorithm>
) -> Result<Box<dyn AppendOnlyResumableRecorderMedium + 'static, Global>, Error>
fn open_for_append(
&self,
source_key: &SourceKey<Self::HashAlgorithm>
) -> Result<Box<dyn AppendOnlyResumableRecorderMedium + 'static, Global>, Error>
根据数据源 KEY 打开追加记录介质
sourcefn open_for_create_new(
&self,
source_key: &SourceKey<Self::HashAlgorithm>
) -> Result<Box<dyn AppendOnlyResumableRecorderMedium + 'static, Global>, Error>
fn open_for_create_new(
&self,
source_key: &SourceKey<Self::HashAlgorithm>
) -> Result<Box<dyn AppendOnlyResumableRecorderMedium + 'static, Global>, Error>
根据数据源 KEY 创建追加记录介质
sourcefn delete(
&self,
source_key: &SourceKey<Self::HashAlgorithm>
) -> Result<(), Error>
fn delete(
&self,
source_key: &SourceKey<Self::HashAlgorithm>
) -> Result<(), Error>
根据数据源 KEY 删除记录介质
sourcefn open_for_async_read(
&'a self,
source_key: &'a SourceKey<Self::HashAlgorithm>
) -> Pin<Box<dyn Future<Output = Result<Box<dyn ReadOnlyAsyncResumableRecorderMedium + 'static, Global>, Error>> + Send + 'a, Global>>
fn open_for_async_read(
&'a self,
source_key: &'a SourceKey<Self::HashAlgorithm>
) -> Pin<Box<dyn Future<Output = Result<Box<dyn ReadOnlyAsyncResumableRecorderMedium + 'static, Global>, Error>> + Send + 'a, Global>>
根据数据源 KEY 打开异步只读记录介质
sourcefn open_for_async_append(
&'a self,
source_key: &'a SourceKey<Self::HashAlgorithm>
) -> Pin<Box<dyn Future<Output = Result<Box<dyn AppendOnlyAsyncResumableRecorderMedium + 'static, Global>, Error>> + Send + 'a, Global>>
fn open_for_async_append(
&'a self,
source_key: &'a SourceKey<Self::HashAlgorithm>
) -> Pin<Box<dyn Future<Output = Result<Box<dyn AppendOnlyAsyncResumableRecorderMedium + 'static, Global>, Error>> + Send + 'a, Global>>
根据数据源 KEY 打开异步追加记录介质
sourcefn open_for_async_create_new(
&'a self,
source_key: &'a SourceKey<Self::HashAlgorithm>
) -> Pin<Box<dyn Future<Output = Result<Box<dyn AppendOnlyAsyncResumableRecorderMedium + 'static, Global>, Error>> + Send + 'a, Global>>
fn open_for_async_create_new(
&'a self,
source_key: &'a SourceKey<Self::HashAlgorithm>
) -> Pin<Box<dyn Future<Output = Result<Box<dyn AppendOnlyAsyncResumableRecorderMedium + 'static, Global>, Error>> + Send + 'a, Global>>
根据数据源 KEY 创建异步追加记录介质