Crate qiniu_upload_manager
source ·Expand description
qiniu-upload-manager
七牛上传管理
基于 qiniu-apis
提供针对七牛对象的上传功能
(同时提供阻塞客户端和异步客户端,异步客户端则需要启用 async
功能)。
功能描述
async
启用异步接口。
ureq
导入 qiniu-ureq
作为 HTTP 客户端。
isahc
导入 qiniu-isahc
作为 HTTP 客户端。
reqwest
导入 qiniu-reqwest
作为 HTTP 客户端。
c_ares
启用 c-ares
库作为 DNS 解析器。
trust_dns
启用 trust-dns
库作为 DNS 解析器。
dns-over-https
启用 trust-dns
库作为 DNS 解析器,并使用 DOH 协议。
dns-over-tls
启用 trust-dns
库作为 DNS 解析器,并使用 DOT 协议。
代码示例
用自动上传器上传文件
阻塞代码示例
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?;
Re-exports
pub use qiniu_apis as apis;
pub use qiniu_apis::http_client::mime;
Modules
将所有 Trait 全部重新导出,方便统一导入
Structs
总是选择分片上传
总是选择单请求上传
异步数据源阅读器
异步文件数据源
AsyncSeekableSource
async
可异步寻址的数据源
不可寻址的异步数据源
自动上传器
自动上传构建器
自动上传器对象参数
自动上传器对象参数构建器
上传并发数
并发数提供者反馈
并发数提供者反馈构建器
分片大小提供者反馈
分片大小提供者反馈构建器
数据源阅读器
无断点恢复记录器
无断点恢复记录介质
文件数据源
文件系统断点恢复记录器
固定并发数提供者
固定分片大小提供者
固定阀值的可恢复策略
表单上传器
获取可恢复策略的选项
受限的分片大小提供者
分片上传器 V1
被 分片上传器 V1 初始化的分片信息
已经通过 分片上传器 V1 上传的分片信息
分片上传器 V2
被 分片上传器 V2 初始化的分片信息
已经通过 分片上传器 V2 上传的分片信息
整数倍分片大小的可恢复策略
整数倍分片大小提供者
对象上传参数
对象上传参数构建器
分片大小
重新初始化分片信息的选项
重新初始化分片信息的选项构建器
可寻址的数据源
串行分片上传调度器
数据源 KEY
不可寻址的数据源
上传管理器
上传管理构建器
上传凭证签发器
上传凭证签发构建器
上传进度信息
Enums
期望的对象分片上传器
期望的分片上传调度器
可恢复策略
期望的对象单请求上传器
Traits
异步追加介质接口
AsyncDataSource
async
异步数据源接口
并发数获取接口
分片大小获取接口
数据源接口
DynAsyncRead
async
异步输入流
阻塞输入流
初始化的分片信息
分片上传器接口
分片上传调度器接口
分片上传调度器扩展接口
分片上传回调函数提供者
异步只读介质接口
可恢复策略获取接口
断点恢复记录器
单请求上传器接口
已经上传的分片信息
上传回调函数提供者