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§

prelude: 将所有 Trait 全部重新导出，方便统一导入

Structs§

AlwaysMultiParts: 总是选择分片上传
AlwaysSinglePart: 总是选择单请求上传
AsyncDataSourceReader: 异步数据源阅读器
AsyncFileDataSource: 异步文件数据源
AsyncSeekableSource: 可异步寻址的数据源
AsyncUnseekableDataSource: 不可寻址的异步数据源
AutoUploader: 自动上传器
AutoUploaderBuilder: 自动上传构建器
AutoUploaderObjectParams: 自动上传器对象参数
AutoUploaderObjectParamsBuilder: 自动上传器对象参数构建器
Concurrency: 上传并发数
ConcurrencyProviderFeedback: 并发数提供者反馈
ConcurrencyProviderFeedbackBuilder: 并发数提供者反馈构建器
ConcurrentMultiPartsUploaderScheduler: 并行分片上传调度器
DataPartitionProviderFeedback: 分片大小提供者反馈
DataPartitionProviderFeedbackBuilder: 分片大小提供者反馈构建器
DataSourceReader: 数据源阅读器
DummyResumableRecorder: 无断点恢复记录器
DummyResumableRecorderMedium: 无断点恢复记录介质
FileDataSource: 文件数据源
FileSystemResumableRecorder: 文件系统断点恢复记录器
FixedConcurrencyProvider: 固定并发数提供者
FixedDataPartitionProvider: 固定分片大小提供者
FixedThresholdResumablePolicy: 固定阀值的可恢复策略
FormUploader: 表单上传器
GetPolicyOptions: 获取可恢复策略的选项
LimitedDataPartitionProvider: 受限的分片大小提供者
MultiPartsV1Uploader: 分片上传器 V1
MultiPartsV1UploaderInitializedObject: 被分片上传器 V1 初始化的分片信息
MultiPartsV1UploaderUploadedPart: 已经通过分片上传器 V1 上传的分片信息
MultiPartsV2Uploader: 分片上传器 V2
MultiPartsV2UploaderInitializedObject: 被分片上传器 V2 初始化的分片信息
MultiPartsV2UploaderUploadedPart: 已经通过分片上传器 V2 上传的分片信息
MultiplePartitionsResumablePolicyProvider: 整数倍分片大小的可恢复策略
MultiplyDataPartitionProvider: 整数倍分片大小提供者
ObjectParams: 对象上传参数
ObjectParamsBuilder: 对象上传参数构建器
PartSize: 分片大小
ReinitializeOptions: 重新初始化分片信息的选项
ReinitializeOptionsBuilder: 重新初始化分片信息的选项构建器
SeekableSource: 可寻址的数据源
SerialMultiPartsUploaderScheduler: 串行分片上传调度器
SourceKey: 数据源 KEY
UnseekableDataSource: 不可寻址的数据源
UploadManager: 上传管理器
UploadManagerBuilder: 上传管理构建器
UploadTokenSigner: 上传凭证签发器
UploadTokenSignerBuilder: 上传凭证签发构建器
UploadingProgressInfo: 上传进度信息

Enums§

MultiPartsUploaderPrefer: 期望的对象分片上传器
MultiPartsUploaderSchedulerPrefer: 期望的分片上传调度器
ResumablePolicy: 可恢复策略
SinglePartUploaderPrefer: 期望的对象单请求上传器

Traits§

AppendOnlyAsyncResumableRecorderMedium: 异步追加介质接口
AppendOnlyResumableRecorderMedium: 追加介质接口
AsyncDataSource: 异步数据源接口
ConcurrencyProvider: 并发数获取接口
DataPartitionProvider: 分片大小获取接口
DataSource: 数据源接口
DynAsyncRead: 异步输入流
DynRead: 阻塞输入流
InitializedParts: 初始化的分片信息
MultiPartsUploader: 分片上传器接口
MultiPartsUploaderScheduler: 分片上传调度器接口
MultiPartsUploaderSchedulerExt: 分片上传调度器扩展接口
MultiPartsUploaderWithCallbacks: 分片上传回调函数提供者
ReadOnlyAsyncResumableRecorderMedium: 异步只读介质接口
ReadOnlyResumableRecorderMedium: 只读介质接口
ResumablePolicyProvider: 可恢复策略获取接口
ResumableRecorder: 断点恢复记录器
SinglePartUploader: 单请求上传器接口
UploadedPart: 已经上传的分片信息
UploaderWithCallbacks: 上传回调函数提供者

Crate qiniu_upload_managerCopy item path