Struct qiniu_upload_manager::AutoUploader

pub struct AutoUploader<H: Digest = Sha1> { /* private fields */ }

自动上传器

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

用自动上传器上传文件

阻塞代码示例

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<H: Digest + 'static> AutoUploader<H>

pub fn new(upload_manager: UploadManager) -> Self

创建自动上传器

Examples found in repository

src/upload_manager.rs (line 97)

    pub fn auto_uploader<H: Digest + Send + 'static>(&self) -> AutoUploader<H> {
        AutoUploader::<H>::new(self.to_owned())
    }

pub fn builder(upload_manager: UploadManager) -> AutoUploaderBuilder<H>

构建自动上传构建器

Examples found in repository

src/upload_manager.rs (line 103)

    pub fn auto_uploader_builder<H: Digest + Send + 'static>(&self) -> AutoUploaderBuilder<H> {
        AutoUploader::<H>::builder(self.to_owned())
    }

impl<H: Digest + Send + 'static> AutoUploader<H>

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<H: Digest> Clone for AutoUploader<H>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<H: Debug + Digest> Debug for AutoUploader<H>

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

Formats the value using the given formatter.

impl<H: Digest> MultiPartsUploaderWithCallbacks for AutoUploader<H>

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

设置分片上传回调函数

impl<H: Digest> UploaderWithCallbacks for AutoUploader<H>

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

设置请求前的回调函数

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

设置上传进度回调函数

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

设置响应成功的回调函数

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

设置响应错误的回调函数