awss3

Documentation

Index

• type BucketMgr
  • func NewBucketMgr(s3cli *s3.S3, bucketName string) *BucketMgr
  • func (b *BucketMgr) DeleteObjects(objectKeys []string, options ...types.OpOption) (result types.DeleteObjectResp, err error)
  • func (b *BucketMgr) GetObject(objectKey string, options ...types.OpOption) (io.ReadCloser, int64, error)
  • func (b *BucketMgr) GetObjectSignUrl(objectKey string, expire time.Duration, options ...types.OpOption) (result string, err error)
  • func (b *BucketMgr) ListObject(prefix string, options ...types.OpOption) (result types.ListObjectResp, err error)
  • func (b *BucketMgr) PutObject(objectKey string, reader io.Reader, options ...types.OpOption) error
• type CustomReader
  • func NewCustomReader(readerAtSeeker readerAtSeeker, progressFn types.ProgressFn) *CustomReader
  • func (r *CustomReader) Close()
  • func (r *CustomReader) Read(p []byte) (int, error)
  • func (r *CustomReader) ReadAt(p []byte, off int64) (int, error)
  • func (r *CustomReader) Seek(offset int64, whence int) (int64, error)
• type S3Mgr
  • func New(s3cli *s3.S3) *S3Mgr
  • func (s *S3Mgr) Bucket(bucketName string) types.BucketMgrInterface
  • func (s *S3Mgr) BucketNative(bucketName string) *BucketMgr
  • func (s *S3Mgr) CreateBucket(bucketName string) (types.BucketMgrInterface, error)
  • func (s *S3Mgr) DeleteBucket(bucketName string) error
  • func (s *S3Mgr) ListBucket() (result types.ListBucketResp, err error)
  • func (s *S3Mgr) ListBucketNative() (*s3.ListBucketsOutput, error)

Types

type BucketMgr

type BucketMgr struct {
	*s3.S3
	types.Op
	// contains filtered or unexported fields
}

func NewBucketMgr

func NewBucketMgr(s3cli *s3.S3, bucketName string) *BucketMgr

func (*BucketMgr) DeleteObjects

func (b *BucketMgr) DeleteObjects(objectKeys []string, options ...types.OpOption) (result types.DeleteObjectResp, err error)

func (*BucketMgr) GetObject

func (b *BucketMgr) GetObject(objectKey string, options ...types.OpOption) (io.ReadCloser, int64, error)

func (*BucketMgr) GetObjectSignUrl

func (b *BucketMgr) GetObjectSignUrl(objectKey string, expire time.Duration, options ...types.OpOption) (result string, err error)

func (*BucketMgr) ListObject

func (b *BucketMgr) ListObject(prefix string, options ...types.OpOption) (result types.ListObjectResp, err error)

func (*BucketMgr) PutObject

func (b *BucketMgr) PutObject(objectKey string, reader io.Reader, options ...types.OpOption) error

type CustomReader

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

func NewCustomReader

func NewCustomReader(readerAtSeeker readerAtSeeker, progressFn types.ProgressFn) *CustomReader

func (*CustomReader) Close

func (r *CustomReader) Close()

func (*CustomReader) Read

func (r *CustomReader) Read(p []byte) (int, error)

func (*CustomReader) ReadAt

func (r *CustomReader) ReadAt(p []byte, off int64) (int, error)

func (*CustomReader) Seek

func (r *CustomReader) Seek(offset int64, whence int) (int64, error)

type S3Mgr

type S3Mgr struct {
	*s3.S3
}

func New

func New(s3cli *s3.S3) *S3Mgr

func (*S3Mgr) Bucket

func (s *S3Mgr) Bucket(bucketName string) types.BucketMgrInterface

func (*S3Mgr) BucketNative

func (s *S3Mgr) BucketNative(bucketName string) *BucketMgr

func (*S3Mgr) CreateBucket

func (s *S3Mgr) CreateBucket(bucketName string) (types.BucketMgrInterface, error)

func (*S3Mgr) DeleteBucket

func (s *S3Mgr) DeleteBucket(bucketName string) error

func (*S3Mgr) ListBucket

func (s *S3Mgr) ListBucket() (result types.ListBucketResp, err error)

func (*S3Mgr) ListBucketNative

func (s *S3Mgr) ListBucketNative() (*s3.ListBucketsOutput, error)