Trait qiniu_sdk::prelude::MultiPartsUploaderScheduler

pub trait MultiPartsUploaderScheduler<A>: DynClone + Send + Sync + Debugwhere
    A: Digest,{
    fn set_concurrency_provider(
        &mut self,
        concurrency_provider: Box<dyn ConcurrencyProvider + 'static, Global>
    );
    fn set_data_partition_provider(
        &mut self,
        data_partition_provider: Box<dyn DataPartitionProvider + 'static, Global>
    );
    fn upload(
        &self,
        source: Box<dyn DataSource<A> + 'static, Global>,
        params: ObjectParams
    ) -> Result<Value, Error>;
    fn async_upload(
        &self,
        source: Box<dyn AsyncDataSource<A> + 'static, Global>,
        params: ObjectParams
    ) -> Pin<Box<dyn Future<Output = Result<Value, Error>> + Send, Global>>;
}

分片上传调度器接口

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

Required Methods

fn set_concurrency_provider(
    &mut self,
    concurrency_provider: Box<dyn ConcurrencyProvider + 'static, Global>
)

设置并发数提供者

fn set_data_partition_provider(
    &mut self,
    data_partition_provider: Box<dyn DataPartitionProvider + 'static, Global>
)

设置分片大小提供者

fn upload(
    &self,
    source: Box<dyn DataSource<A> + 'static, Global>,
    params: ObjectParams
) -> Result<Value, Error>

上传数据源

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

fn async_upload(
    &self,
    source: Box<dyn AsyncDataSource<A> + 'static, Global>,
    params: ObjectParams
) -> Pin<Box<dyn Future<Output = Result<Value, Error>> + Send, Global>>

异步上传数据源

Implementations on Foreign Types

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

fn set_concurrency_provider(
    &mut self,
    concurrency_provider: Box<dyn ConcurrencyProvider + 'static, Global>
)

fn set_data_partition_provider(
    &mut self,
    data_partition_provider: Box<dyn DataPartitionProvider + 'static, Global>
)

fn upload(
    &self,
    source: Box<dyn DataSource<A> + 'static, Global>,
    params: ObjectParams
) -> Result<Value, Error>

fn async_upload(
    &self,
    source: Box<dyn AsyncDataSource<A> + 'static, Global>,
    params: ObjectParams
) -> Pin<Box<dyn Future<Output = Result<Value, Error>> + Send, Global>>

impl<'a, A, T> MultiPartsUploaderScheduler<A> for &'a mut Twhere
    A: Digest,
    T: 'a + MultiPartsUploaderScheduler<A> + ?Sized,
    &'a mut T: DynClone + Send + Sync + Debug,

fn set_concurrency_provider(
    &mut self,
    concurrency_provider: Box<dyn ConcurrencyProvider + 'static, Global>
)

fn set_data_partition_provider(
    &mut self,
    data_partition_provider: Box<dyn DataPartitionProvider + 'static, Global>
)

fn upload(
    &self,
    source: Box<dyn DataSource<A> + 'static, Global>,
    params: ObjectParams
) -> Result<Value, Error>

fn async_upload(
    &self,
    source: Box<dyn AsyncDataSource<A> + 'static, Global>,
    params: ObjectParams
) -> Pin<Box<dyn Future<Output = Result<Value, Error>> + Send, Global>>

Implementors

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

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