Struct FormUploader

pub struct FormUploader { /* private fields */ }

表单上传器

通过七牛表单上传 API 一次上传整个数据流

用表单上传器上传文件

阻塞代码示例

use qiniu_upload_manager::{
    apis::credential::Credential, prelude::*, 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 uploader = upload_manager.form_uploader();
uploader.upload_path("/home/qiniu/test.png", params)?;

异步代码示例

use qiniu_upload_manager::{
    apis::credential::Credential, prelude::*, 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 uploader = upload_manager.form_uploader();
uploader.async_upload_path("/home/qiniu/test.png", params).await?;

Trait Implementations

impl Clone for FormUploader

fn clone(&self) -> FormUploader

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FormUploader

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

Formats the value using the given formatter.

impl SinglePartUploader for FormUploader

fn new(upload_manager: UploadManager) -> Self

创建单请求上传器

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

上传指定路径的文件

fn upload_reader<R: Read + 'static>( &self, reader: R, params: ObjectParams, ) -> ApiResult<Value>

上传输入流的数据

fn async_upload_path<'a>( &'a self, path: impl AsRef<Path> + Send + Sync + 'a, params: ObjectParams, ) -> BoxFuture<'a, ApiResult<Value>>

Available on crate feature async only.

异步上传指定路径的文件

fn async_upload_reader<R: AsyncRead + Unpin + Send + Sync + 'static>( &self, reader: R, params: ObjectParams, ) -> BoxFuture<'_, ApiResult<Value>>

Available on crate feature async only.

上传异步输入流的数据

impl UploaderWithCallbacks for FormUploader

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

设置响应错误的回调函数