s3wrapper

May 10, 2018

Changes in this version

+ func FormatS3Uri(bucket string, key string) string

+ type ListOutput struct

+ Bucket *string

+ FullKey *string

+ IsPrefix bool

+ Key *string

+ LastModified *time.Time

+ Size *int64

+ type S3Wrapper struct

+ func New(svc *s3.S3) *S3Wrapper

+ func (w *S3Wrapper) CopyAll(keys chan *ListOutput, source, dest string, delimiter string, ...) chan *ListOutput

+ func (w *S3Wrapper) DeleteObjects(keys chan *ListOutput) chan *ListOutput

+ func (w *S3Wrapper) GetAll(keys chan *ListOutput, skipExisting bool) chan *ListOutput

+ func (w *S3Wrapper) GetReader(bucket string, key string) (io.ReadCloser, error)

+ func (w *S3Wrapper) List(s3Uri string, recursive bool, delimiter string, keyRegex *string) chan *ListOutput

+ func (w *S3Wrapper) ListAll(s3Uris []string, recursive bool, delimiter string, keyRegex *string) chan *ListOutput

+ func (w *S3Wrapper) ListBuckets(s3Uri string) ([]string, error)

+ func (w *S3Wrapper) Stream(keys chan *ListOutput, includeKeyName bool, raw bool) chan string

+ func (w *S3Wrapper) WithMaxConcurrency(maxConcurrency int) *S3Wrapper