Trait qiniu_upload_manager::MultiPartsUploader

source · 
pub trait MultiPartsUploader: Sealed + MultiPartsUploaderWithCallbacks + Clone + Send + Sync + Debug {
    type HashAlgorithm: Digest + Send + 'static;
    type InitializedParts: InitializedParts + 'static;
    type UploadedPart: UploadedPart;
    type AsyncInitializedParts: InitializedParts + 'static;
    type AsyncUploadedPart: UploadedPart;

    fn new<R: ResumableRecorder<HashAlgorithm = Self::HashAlgorithm> + 'static>(
        upload_manager: UploadManager,
        resumable_recorder: R
    ) -> Self;
    fn upload_manager(&self) -> &UploadManager;
    fn initialize_parts<D: DataSource<Self::HashAlgorithm> + 'static>(
        &self,
        source: D,
        params: ObjectParams
    ) -> ApiResult<Self::InitializedParts>;
    fn upload_part(
        &self,
        initialized: &Self::InitializedParts,
        data_partitioner_provider: &dyn DataPartitionProvider
    ) -> ApiResult<Option<Self::UploadedPart>>;
    fn complete_parts(
        &self,
        initialized: &Self::InitializedParts,
        parts: &[Self::UploadedPart]
    ) -> ApiResult<Value>;
    fn reinitialize_parts(
        &self,
        initialized: &mut Self::InitializedParts,
        options: ReinitializeOptions
    ) -> ApiResult<()>;
    fn try_to_resume_parts<D: DataSource<Self::HashAlgorithm> + 'static>(
        &self,
        source: D,
        params: ObjectParams
    ) -> Option<Self::InitializedParts>;
    fn async_initialize_parts<D: AsyncDataSource<Self::HashAlgorithm> + 'static>(
        &self,
        source: D,
        params: ObjectParams
    ) -> BoxFuture<'_, ApiResult<Self::AsyncInitializedParts>>;
    fn async_upload_part<'r>(
        &'r self,
        initialized: &'r Self::AsyncInitializedParts,
        data_partitioner_provider: &'r dyn DataPartitionProvider
    ) -> BoxFuture<'r, ApiResult<Option<Self::AsyncUploadedPart>>>;
    fn async_complete_parts<'r>(
        &'r self,
        initialized: &'r Self::AsyncInitializedParts,
        parts: &'r [Self::AsyncUploadedPart]
    ) -> BoxFuture<'r, ApiResult<Value>>;
    fn async_reinitialize_parts<'r>(
        &'r self,
        initialized: &'r mut Self::AsyncInitializedParts,
        options: ReinitializeOptions
    ) -> BoxFuture<'r, ApiResult<()>>;
    fn try_to_async_resume_parts<D: AsyncDataSource<Self::HashAlgorithm> + 'static>(
        &self,
        source: D,
        params: ObjectParams
    ) -> BoxFuture<'_, Option<Self::AsyncInitializedParts>>;
}
Expand description

分片上传器接口

将数据源通过多个分片的方式逐一上传，适合数据量较大的数据源，可以提供断点恢复的能力。

Required Associated Types

数据源 KEY 的哈希算法

初始化的分片信息

已经上传的分片信息

Available on crate feature async only.

初始化的异步分片信息

Available on crate feature async only.

已经上传的异步分片信息

Required Methods

创建分片上传器

获取初始化使用的上传管理器

初始化分片信息

该步骤只负责初始化分片，但不实际上传数据，如果提供了有效的断点续传记录器，则可以尝试在这一步找到记录。

该方法的异步版本为 Self::async_initialize_parts。

上传分片

实际上传的分片大小由提供的分片大小提供者获取。

如果返回 [Ok(None)] 则表示已经没有更多分片可以上传。

该方法的异步版本为 Self::async_upload_part。

完成分片上传

在这步成功返回后，对象即可被读取。

该方法的异步版本为 Self::async_complete_parts。

重新初始化分片信息

该步骤负责将先前已经初始化过的分片信息全部重置，清空断点续传记录器中的记录，之后从头上传整个文件

该方法的异步版本为 Self::async_reinitialize_parts。

尝试恢复记录

如果提供了有效的断点续传记录器，该方法可以尝试在找到记录，如果找不到记录，或记录无法读取，则返回 None。

该方法的异步版本为 [Self::try_to_async_resume_records]。

Available on crate feature async only.

异步初始化分片信息

该步骤只负责初始化分片，但不实际上传数据，如果提供了有效的断点续传记录器，则可以尝试在这一步找到记录。

Available on crate feature async only.

异步上传分片

实际上传的分片大小由提供的分片大小提供者获取。

如果返回 [Ok(None)] 则表示已经没有更多分片可以上传。

Available on crate feature async only.

异步完成分片上传

在这步成功返回后，对象即可被读取。

Available on crate feature async only.

异步重新初始化分片信息

该步骤负责将先前已经初始化过的分片信息全部重置，清空断点续传记录器中的记录，之后从头上传整个文件

Available on crate feature async only.

异步尝试恢复记录

如果提供了有效的断点续传记录器，该方法可以尝试在找到记录，如果找不到记录，或记录无法读取，则返回 None。

Implementors