Trait qiniu_upload_manager::MultiPartsUploaderScheduler

pub trait MultiPartsUploaderScheduler<A: Digest>: DynClone + Send + Sync + Debug {
    fn set_concurrency_provider(
        &mut self,
        concurrency_provider: Box<dyn ConcurrencyProvider>
    );
    fn set_data_partition_provider(
        &mut self,
        data_partition_provider: Box<dyn DataPartitionProvider>
    );
    fn upload(
        &self,
        source: Box<dyn DataSource<A>>,
        params: ObjectParams
    ) -> ApiResult<Value>;
    fn async_upload(
        &self,
        source: Box<dyn AsyncDataSource<A>>,
        params: ObjectParams
    ) -> BoxFuture<'_, ApiResult<Value>>;
}

分片上传调度器接口

负责分片上传的调度，包括初始化分片信息、上传分片、完成分片上传。

Required Methods

fn set_concurrency_provider(
    &mut self,
    concurrency_provider: Box<dyn ConcurrencyProvider>
)

设置并发数提供者

fn set_data_partition_provider(
    &mut self,
    data_partition_provider: Box<dyn DataPartitionProvider>
)

设置分片大小提供者

fn upload(
    &self,
    source: Box<dyn DataSource<A>>,
    params: ObjectParams
) -> ApiResult<Value>

上传数据源

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

fn async_upload(
    &self,
    source: Box<dyn AsyncDataSource<A>>,
    params: ObjectParams
) -> BoxFuture<'_, ApiResult<Value>>

Available on crate feature async only.

异步上传数据源

Trait Implementations

impl<'clone, A: Digest> Clone for Box<dyn MultiPartsUploaderScheduler<A> + 'clone>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'clone, A: Digest> Clone for Box<dyn MultiPartsUploaderScheduler<A> + Send + 'clone>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'clone, A: Digest> Clone for Box<dyn MultiPartsUploaderScheduler<A> + Send + Sync + 'clone>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'clone, A: Digest> Clone for Box<dyn MultiPartsUploaderScheduler<A> + Sync + 'clone>

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<'a, A: Digest, T: 'a + MultiPartsUploaderScheduler<A> + ?Sized> MultiPartsUploaderScheduler<A> for &'a mut Twhere
    &'a mut T: DynClone + Send + Sync + Debug,

fn set_concurrency_provider(
    &mut self,
    concurrency_provider: Box<dyn ConcurrencyProvider>
)

fn set_data_partition_provider(
    &mut self,
    data_partition_provider: Box<dyn DataPartitionProvider>
)

fn upload(
    &self,
    source: Box<dyn DataSource<A>>,
    params: ObjectParams
) -> ApiResult<Value>

fn async_upload(
    &self,
    source: Box<dyn AsyncDataSource<A>>,
    params: ObjectParams
) -> BoxFuture<'_, ApiResult<Value>>

Available on crate feature async only.

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

fn set_concurrency_provider(
    &mut self,
    concurrency_provider: Box<dyn ConcurrencyProvider>
)

fn set_data_partition_provider(
    &mut self,
    data_partition_provider: Box<dyn DataPartitionProvider>
)

fn upload(
    &self,
    source: Box<dyn DataSource<A>>,
    params: ObjectParams
) -> ApiResult<Value>

fn async_upload(
    &self,
    source: Box<dyn AsyncDataSource<A>>,
    params: ObjectParams
) -> BoxFuture<'_, ApiResult<Value>>

Available on crate feature async only.

Implementors

impl<M: MultiPartsUploader + 'static> MultiPartsUploaderScheduler<<M as MultiPartsUploader>::HashAlgorithm> for ConcurrentMultiPartsUploaderScheduler<M>

impl<M: MultiPartsUploader> MultiPartsUploaderScheduler<<M as MultiPartsUploader>::HashAlgorithm> for SerialMultiPartsUploaderScheduler<M>