downloader

type ConcurrentDownloaderOptions struct {
	DownloaderOptions
	Concurrency       uint                                // 并发度
	PartSize          uint64                              // 分片大小
	ResumableRecorder resumablerecorder.ResumableRecorder // 可恢复记录仪
}

type DefaultSrcURLsProviderOptions struct {
	region.BucketRegionsQueryOptions

	// Bucket 服务器地址
	BucketHosts region.Endpoints
}

type DestinationDownloadOptions struct {
	// 对象下载附加 HTTP Header
	Header http.Header
	// 对象下载进度
	OnDownloadingProgress func(*DownloadingProgress)
	// 对象 Header 获取回调
	OnResponseHeader func(http.Header)
}

type DestinationDownloader interface {
	Download(context.Context, URLsIter, destination.Destination, *DestinationDownloadOptions) (uint64, error)
}

type DirectoryOptions struct {
	// 是否使用 HTTP 协议，默认为不使用
	UseInsecureProtocol bool

	// 空间名称
	BucketName string

	// 对象前缀
	ObjectPrefix string

	// 下载并发度
	ObjectConcurrency int

	// 下载 URL 生成器
	DownloadURLsProvider DownloadURLsProvider

	// 下载前回调函数
	BeforeObjectDownload func(objectName string, objectOptions *ObjectOptions)

	// 下载进度
	OnDownloadingProgress func(objectName string, progress *DownloadingProgress)

	// 对象下载成功后回调
	OnObjectDownloaded func(objectName string, info *DownloadedObjectInfo)

	// 是否下载指定对象
	ShouldDownloadObject func(objectName string) bool

	// 分隔符，默认为 /
	PathSeparator string
}

type DomainsQueryURLsProviderOptions struct {
	http_client.Options

	// 压缩周期（默认：60s）
	CompactInterval time.Duration

	// 持久化路径（默认：$TMPDIR/qiniu-golang-sdk/domain_v2_01.cache.json）
	PersistentFilePath string

	// 持久化周期（默认：60s）
	PersistentDuration time.Duration

	// 缓存有效周期（默认：3600s）
	CacheTTL time.Duration
}

type DownloadManager struct {
	// contains filtered or unexported fields
}

type DownloadManagerOptions struct {
	// HTTP 客户端选项
	httpclient.Options

	// 目标下载器
	DestinationDownloader DestinationDownloader

	// 分片列举版本，如果不填写，默认为 V1
	ListerVersion objects.ListerVersion

	// 下载 URL 生成器
	DownloadURLsProvider DownloadURLsProvider
}

type DownloadURLsProvider interface {
	GetURLsIter(context.Context, string, *GenerateOptions) (URLsIter, error)
}

type DownloadedObjectInfo struct {
	Size uint64 // 对象大小
}

type DownloaderOptions struct {
	Client   clientv2.Client   // HTTP 客户端，如果不配置则使用默认的 HTTP 客户端
	RetryMax int               // 最大重试次数，如果不配置，默认为 9
	Backoff  backoff.Backoff   // 重试时间间隔 v2，优先级高于 RetryInterval
	Resolver resolver.Resolver // 主备域名解析器
	Chooser  chooser.Chooser   // IP 选择器

	BeforeResolve func(*http.Request)                                         // 域名解析前回调函数
	AfterResolve  func(*http.Request, []net.IP)                               // 域名解析后回调函数
	ResolveError  func(*http.Request, error)                                  // 域名解析错误回调函数
	BeforeBackoff func(*http.Request, *retrier.RetrierOptions, time.Duration) // 退避前回调函数
	AfterBackoff  func(*http.Request, *retrier.RetrierOptions, time.Duration) // 退避后回调函数
	BeforeRequest func(*http.Request, *retrier.RetrierOptions)                // 请求前回调函数
	AfterResponse func(*http.Response, *retrier.RetrierOptions, error)        // 请求后回调函数
}

type DownloadingProgress struct {
	Downloaded uint64 // 已经下载的数据量，单位为字节
	TotalSize  uint64 // 总数据量，单位为字节
}

type GenerateOptions struct {
	// 空间名称，可选
	BucketName string

	// 文件处理命令，可选
	Command string

	// 是否使用 HTTP 协议，默认为不使用
	UseInsecureProtocol bool
}

type ObjectOptions struct {
	DestinationDownloadOptions
	GenerateOptions

	// 下载 URL 生成器
	DownloadURLsProvider DownloadURLsProvider
}

type SignOptions struct {
	// 签名有效期，如果不填写，默认为 3 分钟
	TTL time.Duration
}

type Signer interface {
	Sign(context.Context, *url.URL, *SignOptions) error
}

type URLsIter interface {
	// 获取首个 URL
	Peek(*url.URL) (bool, error)
	// 切换到下一个 URL
	Next()
	// 重置迭代器
	Reset()
	// 复制迭代器
	Clone() URLsIter
}