Struct MultiPartsV2Uploader

pub struct MultiPartsV2Uploader<H: Digest = Sha1> { /* private fields */ }

分片上传器 V2

不推荐直接使用这个上传器，而是可以借助 crate::MultiPartsUploaderScheduler 来方便地实现分片上传。

Trait Implementations

impl<H: Digest> Clone for MultiPartsV2Uploader<H>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<H: Digest> Debug for MultiPartsV2Uploader<H>

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

Formats the value using the given formatter.

impl<H: Digest + Send + 'static> MultiPartsUploader for MultiPartsV2Uploader<H>

type HashAlgorithm = H

数据源 KEY 的哈希算法

type InitializedParts = MultiPartsV2UploaderInitializedObject<Box<dyn DataSource<H>>>

初始化的分片信息

type UploadedPart = MultiPartsV2UploaderUploadedPart

已经上传的分片信息

type AsyncInitializedParts = MultiPartsV2UploaderInitializedObject<Box<dyn AsyncDataSource<H>>>

Available on crate feature async only.

初始化的异步分片信息

type AsyncUploadedPart = MultiPartsV2UploaderUploadedPart

Available on crate feature async only.

已经上传的异步分片信息

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 try_to_resume_parts<D: DataSource<Self::HashAlgorithm> + 'static>( &self, source: D, params: ObjectParams, ) -> Option<Self::InitializedParts>

尝试恢复记录

fn reinitialize_parts( &self, initialized: &mut Self::InitializedParts, options: ReinitializeOptions, ) -> ApiResult<()>

重新初始化分片信息

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 async_initialize_parts<D: AsyncDataSource<Self::HashAlgorithm> + 'static>( &self, source: D, params: ObjectParams, ) -> BoxFuture<'_, ApiResult<Self::AsyncInitializedParts>>

Available on crate feature async only.

异步初始化分片信息

fn try_to_async_resume_parts<D: AsyncDataSource<Self::HashAlgorithm> + 'static>( &self, source: D, params: ObjectParams, ) -> BoxFuture<'_, Option<Self::AsyncInitializedParts>>

Available on crate feature async only.

异步尝试恢复记录

fn async_reinitialize_parts<'r>( &'r self, initialized: &'r mut Self::AsyncInitializedParts, options: ReinitializeOptions, ) -> BoxFuture<'_, ApiResult<()>>

Available on crate feature async only.

异步重新初始化分片信息

fn async_upload_part<'r>( &'r self, initialized: &'r Self::AsyncInitializedParts, data_partitioner_provider: &'r dyn DataPartitionProvider, ) -> BoxFuture<'r, ApiResult<Option<Self::AsyncUploadedPart>>>

Available on crate feature async only.

异步上传分片

fn async_complete_parts<'r>( &'r self, initialized: &'r Self::AsyncInitializedParts, parts: &'r [Self::AsyncUploadedPart], ) -> BoxFuture<'r, ApiResult<Value>>

Available on crate feature async only.

异步完成分片上传

impl<H: Digest> MultiPartsUploaderWithCallbacks for MultiPartsV2Uploader<H>

fn on_part_uploaded<F: Fn(&dyn UploadedPart) -> AnyResult<()> + Send + Sync + 'static>( &mut self, callback: F, ) -> &mut Self

设置分片上传回调函数

impl<H: Digest> UploaderWithCallbacks for MultiPartsV2Uploader<H>

fn on_before_request<F: Fn(&mut RequestBuilderParts<'_>) -> AnyResult<()> + Send + Sync + 'static>( &mut self, callback: F, ) -> &mut Self

设置请求前的回调函数

fn on_upload_progress<F: Fn(&UploadingProgressInfo) -> AnyResult<()> + Send + Sync + 'static>( &mut self, callback: F, ) -> &mut Self

设置上传进度回调函数

fn on_response_ok<F: Fn(&mut ResponseParts) -> AnyResult<()> + Send + Sync + 'static>( &mut self, callback: F, ) -> &mut Self

设置响应成功的回调函数

fn on_response_error<F: Fn(&mut ResponseError) -> AnyResult<()> + Send + Sync + 'static>( &mut self, callback: F, ) -> &mut Self

设置响应错误的回调函数