Trait MultiPartsUploaderScheduler

pub trait MultiPartsUploaderScheduler<A>:
    DynClone
    + Send
    + Sync
    + Debug
where
    A: Digest,
{
    // 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,
    ) -> Result<Value, Error>;
    fn async_upload(
        &self,
        source: Box<dyn AsyncDataSource<A>>,
        params: ObjectParams,
    ) -> Pin<Box<dyn Future<Output = Result<Value, Error>> + Send + '_>>;
}

分片上传调度器接口

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

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, ) -> Result<Value, Error>

上传数据源

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

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

异步上传数据源

Implementations on Foreign Types

impl<'a, A, T> MultiPartsUploaderScheduler<A> for &'a mut T

where 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>, )

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

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

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

impl<A, T> MultiPartsUploaderScheduler<A> for Box<T>

where A: Digest, T: MultiPartsUploaderScheduler<A> + ?Sized, 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, ) -> Result<Value, Error>

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

Implementors

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

where M: MultiPartsUploader + 'static,

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

where M: MultiPartsUploader,