transfermanager

Oct 3, 2024

Changes in this version

type DownloadDirectoryInput

+ StripPrefix string

type Option

+ func SkipIfExists() Option

Jul 3, 2024

Changes in this version

+ type DownloadBuffer struct

+ func NewDownloadBuffer(buf []byte) *DownloadBuffer

+ func (db *DownloadBuffer) Bytes() []byte

+ func (db *DownloadBuffer) WriteAt(p []byte, off int64) (n int, err error)

+ type DownloadDirectoryInput struct

+ Bucket string

+ Callback func([]DownloadOutput)

+ EndOffset string

+ LocalDirectory string

+ MatchGlob string

+ OnObjectDownload func(*DownloadOutput)

+ Prefix string

+ StartOffset string

type Downloader

+ func (d *Downloader) DownloadDirectory(ctx context.Context, input *DownloadDirectoryInput) error

type Option

+ func WithPartSize(partSize int64) Option

Jun 10, 2024

Changes in this version

+ type DownloadObjectInput struct

+ Bucket string

+ Callback func(*DownloadOutput)

+ Conditions *storage.Conditions

+ Destination io.WriterAt

+ EncryptionKey []byte

+ Generation *int64

+ Object string

+ Range *DownloadRange

+ type DownloadOutput struct

+ Attrs *storage.ReaderObjectAttrs

+ Bucket string

+ Err error

+ Object string

+ Range *DownloadRange

+ type DownloadRange struct

+ Length int64

+ Offset int64

+ type Downloader struct

+ func NewDownloader(c *storage.Client, opts ...Option) (*Downloader, error)

+ func (d *Downloader) DownloadObject(ctx context.Context, input *DownloadObjectInput) error

+ func (d *Downloader) WaitAndClose() ([]DownloadOutput, error)

+ type Option interface

+ func WithCallbacks() Option

+ func WithPerOpTimeout(timeout time.Duration) Option

+ func WithWorkers(numWorkers int) Option