Struct qiniu_upload_manager::SerialMultiPartsUploaderScheduler

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

串行分片上传调度器

不启动任何线程，仅在本地串行上传分片。

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

阻塞代码示例

use qiniu_upload_manager::{
    apis::credential::Credential, prelude::*, FileSystemResumableRecorder, MultiPartsV2Uploader,
    ObjectParams, SerialMultiPartsUploaderScheduler, 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 = SerialMultiPartsUploaderScheduler::new(MultiPartsV2Uploader::new(
    upload_manager,
    FileSystemResumableRecorder::default(),
));
scheduler.upload_path("/home/qiniu/test.png", params)?;

异步代码示例

use qiniu_upload_manager::{
    apis::credential::Credential, prelude::*, FileSystemResumableRecorder, MultiPartsV2Uploader,
    ObjectParams, SerialMultiPartsUploaderScheduler, 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 = SerialMultiPartsUploaderScheduler::new(MultiPartsV2Uploader::new(
    upload_manager,
    FileSystemResumableRecorder::default(),
));
scheduler.async_upload_path("/home/qiniu/test.png", params).await?;

Trait Implementations

impl<M: Debug> Debug for SerialMultiPartsUploaderScheduler<M>

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

Formats the value using the given formatter.

impl<M: MultiPartsUploader> MultiPartsUploaderScheduler for SerialMultiPartsUploaderScheduler<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>>

This is supported on crate feature async only.

异步上传数据源