Struct ConcurrentMultiPartsUploaderScheduler

pub struct ConcurrentMultiPartsUploaderScheduler<M: MultiPartsUploader> { /* private fields */ }

并行分片上传调度器

在阻塞模式下创建线程池负责上传分片，在异步模式下使用 async-std 的线程池负责上传分片。

用并行分片上传调度器上传文件

阻塞代码示例

use qiniu_upload_manager::{
    apis::credential::Credential, prelude::*, ConcurrentMultiPartsUploaderScheduler,
    FileSystemResumableRecorder, MultiPartsV2Uploader, ObjectParams, UploadManager,
    UploadTokenSigner,
};
use std::time::Duration;
use sha1::Sha1;

let bucket_name = "test-bucket";
let object_name = "test-object";
let upload_manager = UploadManager::builder(UploadTokenSigner::new_credential_provider(
    Credential::new("abcdefghklmnopq", "1234567890"),
    bucket_name,
    Duration::from_secs(3600),
))
.build();
let params = ObjectParams::builder().object_name(object_name).file_name(object_name).build();
let mut scheduler = ConcurrentMultiPartsUploaderScheduler::new(MultiPartsV2Uploader::new(
    upload_manager,
    FileSystemResumableRecorder::<Sha1>::default(),
));
scheduler.upload_path("/home/qiniu/test.png", params)?;

异步代码示例

use qiniu_upload_manager::{
    apis::credential::Credential, prelude::*, ConcurrentMultiPartsUploaderScheduler,
    FileSystemResumableRecorder, MultiPartsV2Uploader, ObjectParams, UploadManager,
    UploadTokenSigner,
};
use std::time::Duration;
use sha1::Sha1;

let bucket_name = "test-bucket";
let object_name = "test-object";
let upload_manager = UploadManager::builder(UploadTokenSigner::new_credential_provider(
    Credential::new("abcdefghklmnopq", "1234567890"),
    bucket_name,
    Duration::from_secs(3600),
))
.build();
let params = ObjectParams::builder().object_name(object_name).file_name(object_name).build();
let mut scheduler = ConcurrentMultiPartsUploaderScheduler::new(MultiPartsV2Uploader::new(
    upload_manager,
    FileSystemResumableRecorder::<Sha1>::default(),
));
scheduler.async_upload_path("/home/qiniu/test.png", params).await?;

Implementations

impl<M: MultiPartsUploader> ConcurrentMultiPartsUploaderScheduler<M>

pub fn new(multi_parts_uploader: M) -> Self

创建并行分片上传调度器

pub fn concurrency_provider(&self) -> &dyn ConcurrencyProvider

获取并发数提供者

pub fn data_partition_provider(&self) -> &dyn DataPartitionProvider

获取分片大小提供者

Trait Implementations

impl<M: Clone + MultiPartsUploader> Clone for ConcurrentMultiPartsUploaderScheduler<M>

fn clone(&self) -> ConcurrentMultiPartsUploaderScheduler<M>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<M: Debug + MultiPartsUploader> Debug for ConcurrentMultiPartsUploaderScheduler<M>

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

Formats the value using the given formatter.

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

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<M::HashAlgorithm>>, params: ObjectParams, ) -> ApiResult<Value>

上传数据源

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

Available on crate feature async only.

异步上传数据源