Struct qiniu_upload_manager::SerialMultiPartsUploaderScheduler

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

串行分片上传调度器

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

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

阻塞代码示例

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

Implementations

impl<M: MultiPartsUploader> SerialMultiPartsUploaderScheduler<M>

pub fn new(multi_parts_uploader: M) -> Self

创建串行分片上传调度器

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

获取分片大小提供者

Trait Implementations

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

fn clone(&self) -> SerialMultiPartsUploaderScheduler<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 SerialMultiPartsUploaderScheduler<M>

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

Formats the value using the given formatter.

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

异步上传数据源