Struct qiniu_upload_manager::AutoUploader

pub struct AutoUploader<CP = FixedConcurrencyProvider, DPP = FixedDataPartitionProvider, RR = FileSystemResumableRecorder, RPP = FixedThresholdResumablePolicy> { /* private fields */ }

自动上传器

使用设置的各种提供者，将文件或是二进制流数据上传。

该类型包含多个泛型参数， CP 表示并发数提供者，默认为固定并发数提供者； DPP 表示分片大小提供者，默认为固定分片大小提供者； RR 表示断点恢复记录器，默认为文件系统断点恢复记录器； RPP 表示可恢复策略，默认为固定阀值可恢复策略。

用自动上传器上传文件

阻塞代码示例

use qiniu_upload_manager::{
    apis::credential::Credential, AutoUploader, AutoUploaderObjectParams, 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 = AutoUploaderObjectParams::builder().object_name(object_name).file_name(object_name).build();
let mut uploader: AutoUploader = upload_manager.auto_uploader();
uploader.upload_path("/home/qiniu/test.png", params)?;

异步代码示例

use qiniu_upload_manager::{
    apis::credential::Credential, AutoUploader, AutoUploaderObjectParams, 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 = AutoUploaderObjectParams::builder().object_name(object_name).file_name(object_name).build();
let mut uploader: AutoUploader = upload_manager.auto_uploader();
uploader.async_upload_path("/home/qiniu/test.png", params).await?;

Implementations

impl<CP: Default, DPP: Default, RR: Default, RPP: Default> AutoUploader<CP, DPP, RR, RPP>

pub fn new(upload_manager: UploadManager) -> Self

创建自动上传器

pub fn builder(
    upload_manager: UploadManager
) -> AutoUploaderBuilder<CP, DPP, RR, RPP>

构建自动上传构建器

impl<CP: ConcurrencyProvider + 'static, DPP: DataPartitionProvider + 'static, RR: ResumableRecorder + 'static, RPP: ResumablePolicyProvider> AutoUploader<CP, DPP, RR, RPP> where
    RR::HashAlgorithm: Send, 

pub fn upload_path(
    &self,
    path: impl AsRef<Path>,
    params: impl Into<AutoUploaderObjectParams>
) -> ApiResult<Value>

阻塞上传指定路径的文件

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

pub fn upload_reader<R: Read + Debug + Send + Sync + 'static>(
    &self,
    reader: R,
    params: impl Into<AutoUploaderObjectParams>
) -> ApiResult<Value>

阻塞上传阅读器的数据

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

pub async fn async_upload_path<'a>(
    &'a self,
    path: impl AsRef<Path> + Send + Sync + 'a,
    params: impl Into<AutoUploaderObjectParams>
) -> ApiResult<Value>

Available on crate feature async only.

异步上传指定路径的文件

pub async fn async_upload_reader<R: AsyncRead + Unpin + Debug + Send + Sync + 'static>(
    &self,
    reader: R,
    params: impl Into<AutoUploaderObjectParams>
) -> ApiResult<Value>

Available on crate feature async only.

异步上传阅读器的数据

Trait Implementations

impl<CP: Debug, DPP: Debug, RR: Debug, RPP: Debug> Debug for AutoUploader<CP, DPP, RR, RPP>

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

Formats the value using the given formatter.

impl<CP: ConcurrencyProvider, DPP: DataPartitionProvider, RR: ResumableRecorder, RPP: ResumablePolicyProvider> MultiPartsUploaderWithCallbacks for AutoUploader<CP, DPP, RR, RPP>

fn on_part_uploaded<F: Fn(&dyn UploadedPart) -> CallbackResult + Send + Sync + 'static>(
    &mut self,
    callback: F
) -> &mut Self

设置分片上传回调函数

impl<CP: ConcurrencyProvider, DPP: DataPartitionProvider, RR: ResumableRecorder, RPP: ResumablePolicyProvider> UploaderWithCallbacks for AutoUploader<CP, DPP, RR, RPP>

fn on_before_request<F: Fn(&mut RequestBuilderParts<'_>) -> CallbackResult + Send + Sync + 'static>(
    &mut self,
    callback: F
) -> &mut Self

设置请求前的回调函数

fn on_upload_progress<F: Fn(&UploadingProgressInfo) -> CallbackResult + Send + Sync + 'static>(
    &mut self,
    callback: F
) -> &mut Self

设置上传进度回调函数

fn on_response_ok<F: Fn(&mut ResponseParts) -> CallbackResult + Send + Sync + 'static>(
    &mut self,
    callback: F
) -> &mut Self

设置响应成功的回调函数

fn on_response_error<F: Fn(&ResponseError) -> CallbackResult + Send + Sync + 'static>(
    &mut self,
    callback: F
) -> &mut Self

设置响应错误的回调函数