Versions in this module Expand all Collapse all v0 v0.3.2 Nov 9, 2018 Changes in this version + const DefaultBatchSize + const DefaultDownloadConcurrency + const DefaultDownloadPartSize + const DefaultUploadConcurrency + const DefaultUploadPartSize + const ErrDeleteBatchFailCode + const MaxUploadParts + const MinUploadPartSize + func GetBucketRegion(ctx aws.Context, c client.ConfigProvider, bucket, regionHint string, ...) (string, error) + func GetBucketRegionWithClient(ctx aws.Context, svc s3iface.S3API, bucket string, opts ...request.Option) (string, error) + func NewBatchError(code, message string, err []Error) awserr.Error + func WithDownloaderRequestOptions(opts ...request.Option) func(*Downloader) + func WithUploaderRequestOptions(opts ...request.Option) func(*Uploader) + type BatchDelete struct + BatchSize int + Client s3iface.S3API + func NewBatchDelete(c client.ConfigProvider, options ...func(*BatchDelete)) *BatchDelete + func NewBatchDeleteWithClient(client s3iface.S3API, options ...func(*BatchDelete)) *BatchDelete + func (d *BatchDelete) Delete(ctx aws.Context, iter BatchDeleteIterator) error + type BatchDeleteIterator interface + DeleteObject func() BatchDeleteObject + Err func() error + Next func() bool + func NewDeleteListIterator(svc s3iface.S3API, input *s3.ListObjectsInput, ...) BatchDeleteIterator + type BatchDeleteObject struct + After func() error + Object *s3.DeleteObjectInput + type BatchDownloadIterator interface + DownloadObject func() BatchDownloadObject + Err func() error + Next func() bool + type BatchDownloadObject struct + After func() error + Object *s3.GetObjectInput + Writer io.WriterAt + type BatchError struct + Errors Errors + func (err *BatchError) Code() string + func (err *BatchError) Error() string + func (err *BatchError) Message() string + func (err *BatchError) OrigErr() error + type BatchUploadIterator interface + Err func() error + Next func() bool + UploadObject func() BatchUploadObject + type BatchUploadObject struct + After func() error + Object *UploadInput + type DeleteListIterator struct + Bucket *string + Paginator request.Pagination + func (iter *DeleteListIterator) DeleteObject() BatchDeleteObject + func (iter *DeleteListIterator) Err() error + func (iter *DeleteListIterator) Next() bool + type DeleteObjectsIterator struct + Objects []BatchDeleteObject + func (iter *DeleteObjectsIterator) DeleteObject() BatchDeleteObject + func (iter *DeleteObjectsIterator) Err() error + func (iter *DeleteObjectsIterator) Next() bool + type DownloadObjectsIterator struct + Objects []BatchDownloadObject + func (batcher *DownloadObjectsIterator) DownloadObject() BatchDownloadObject + func (batcher *DownloadObjectsIterator) Err() error + func (batcher *DownloadObjectsIterator) Next() bool + type Downloader struct + Concurrency int + PartSize int64 + RequestOptions []request.Option + S3 s3iface.S3API + func NewDownloader(c client.ConfigProvider, options ...func(*Downloader)) *Downloader + func NewDownloaderWithClient(svc s3iface.S3API, options ...func(*Downloader)) *Downloader + func (d Downloader) Download(w io.WriterAt, input *s3.GetObjectInput, options ...func(*Downloader)) (n int64, err error) + func (d Downloader) DownloadWithContext(ctx aws.Context, w io.WriterAt, input *s3.GetObjectInput, ...) (n int64, err error) + func (d Downloader) DownloadWithIterator(ctx aws.Context, iter BatchDownloadIterator, opts ...func(*Downloader)) error + type Error struct + Bucket *string + Key *string + OrigErr error + func (err *Error) Error() string + type Errors []Error + func (errs Errors) Error() string + type MultiUploadFailure interface + UploadID func() string + type UploadInput struct + ACL *string + Body io.Reader + Bucket *string + CacheControl *string + ContentDisposition *string + ContentEncoding *string + ContentLanguage *string + ContentMD5 *string + ContentType *string + Expires *time.Time + GrantFullControl *string + GrantRead *string + GrantReadACP *string + GrantWriteACP *string + Key *string + Metadata map[string]*string + RequestPayer *string + SSECustomerAlgorithm *string + SSECustomerKey *string + SSECustomerKeyMD5 *string + SSEKMSKeyId *string + ServerSideEncryption *string + StorageClass *string + Tagging *string + WebsiteRedirectLocation *string + type UploadObjectsIterator struct + Objects []BatchUploadObject + func (batcher *UploadObjectsIterator) Err() error + func (batcher *UploadObjectsIterator) Next() bool + func (batcher *UploadObjectsIterator) UploadObject() BatchUploadObject + type UploadOutput struct + Location string + UploadID string + VersionID *string + type Uploader struct + Concurrency int + LeavePartsOnError bool + MaxUploadParts int + PartSize int64 + RequestOptions []request.Option + S3 s3iface.S3API + func NewUploader(c client.ConfigProvider, options ...func(*Uploader)) *Uploader + func NewUploaderWithClient(svc s3iface.S3API, options ...func(*Uploader)) *Uploader + func (u Uploader) Upload(input *UploadInput, options ...func(*Uploader)) (*UploadOutput, error) + func (u Uploader) UploadWithContext(ctx aws.Context, input *UploadInput, opts ...func(*Uploader)) (*UploadOutput, error) + func (u Uploader) UploadWithIterator(ctx aws.Context, iter BatchUploadIterator, opts ...func(*Uploader)) error