Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrCacheNotFound = errors.New("no cache archive found for the provided keys")
ErrCacheNotFound ...
Functions ¶
This section is empty.
Types ¶
type DefaultDownloader ¶
type DefaultDownloader struct{}
DefaultDownloader ...
func (DefaultDownloader) Download ¶
func (d DefaultDownloader) Download(ctx context.Context, params DownloadParams, logger log.Logger) (string, error)
Download archive from the cache API based on the provided keys in params. If there is no match for any of the keys, the error is ErrCacheNotFound.
type DefaultUploader ¶
type DefaultUploader struct{}
DefaultUploader ...
func (DefaultUploader) Upload ¶
func (u DefaultUploader) Upload(ctx context.Context, params UploadParams, logger log.Logger) error
Upload a cache archive and associate it with the provided cache key
type DownloadParams ¶
type DownloadParams struct {
APIBaseURL string
Token string
CacheKeys []string
DownloadPath string
NumFullRetries int
MaxConcurrency uint
}
DownloadParams ...
type Downloader ¶
Downloader ...
Directories
¶
| Path | Synopsis |
|---|---|
|
Package chunkdownloader provides a reusable, optimized parallel download system.
|
Package chunkdownloader provides a reusable, optimized parallel download system. |
|
Package chunkuploader provides a reusable, optimized chunk upload system for R2/S3 storage.
|
Package chunkuploader provides a reusable, optimized chunk upload system for R2/S3 storage. |
Click to show internal directories.
Click to hide internal directories.