Struct qiniu_upload_manager::ConcurrentMultiPartsUploaderScheduler

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

并行分片上传调度器

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

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

阻塞代码示例

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

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::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;

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::default(),
));
scheduler.async_upload_path("/home/qiniu/test.png", params).await?;

Trait Implementations

impl<M> Clone for ConcurrentMultiPartsUploaderScheduler<M>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

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

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

Formats the value using the given formatter.

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

type MultiPartsUploader = M

分片上传器

fn new(multi_parts_uploader: Self::MultiPartsUploader) -> Self

创建分片上传调度器

fn set_concurrency_provider(
    &mut self,
    concurrency_provider: impl ConcurrencyProvider + 'static
)

设置并发数提供者

fn set_data_partition_provider(
    &mut self,
    data_partition_provider: impl DataPartitionProvider + 'static
)

设置分片大小提供者

fn upload<D: DataSource<<<Self::MultiPartsUploader as MultiPartsUploader>::ResumableRecorder as ResumableRecorder>::HashAlgorithm> + 'static>(
    &self,
    source: D,
    params: ObjectParams
) -> ApiResult<Value>

上传数据源

fn async_upload<D: DataSource<<<Self::MultiPartsUploader as MultiPartsUploader>::ResumableRecorder as ResumableRecorder>::HashAlgorithm> + 'static>(
    &self,
    source: D,
    params: ObjectParams
) -> BoxFuture<'_, ApiResult<Value>>

Available on crate feature async only.

异步上传数据源