wrapper

Documentation

Index

• Constants
• type ClearBucketInput
• type IWrapper
  • func CreateS3Wrapper(config aws.Config, tableBucketsMode bool, directoryBucketsMode bool) IWrapper
• type ListBucketNamesFilteredByKeywordOutput
• type S3TablesWrapper
  • func NewS3TablesWrapper(client client.IS3Tables) *S3TablesWrapper
  • func (s *S3TablesWrapper) CheckAllBucketsExist(ctx context.Context, bucketNames []string) ([]string, error)
  • func (s *S3TablesWrapper) ClearBucket(ctx context.Context, input ClearBucketInput) error
  • func (s *S3TablesWrapper) ListBucketNamesFilteredByKeyword(ctx context.Context, keyword *string) ([]ListBucketNamesFilteredByKeywordOutput, error)
• type S3Wrapper
  • func NewS3Wrapper(client client.IS3) *S3Wrapper
  • func (s *S3Wrapper) CheckAllBucketsExist(ctx context.Context, bucketNames []string) ([]string, error)
  • func (s *S3Wrapper) ClearBucket(ctx context.Context, input ClearBucketInput) error
  • func (s *S3Wrapper) ListBucketNamesFilteredByKeyword(ctx context.Context, keyword *string) ([]ListBucketNamesFilteredByKeywordOutput, error)

Constants

const SDKRetryMaxAttempts = 3

const SemaphoreWeight = 5

Too Many Requests error often occurs, so limit the value

Types

type ClearBucketInput

type ClearBucketInput struct {
	TargetBucket    string // bucket name for S3, bucket arn for S3Tables
	ForceMode       bool
	OldVersionsOnly bool
	QuietMode       bool
}

type IWrapper

type IWrapper interface {
	ClearBucket(ctx context.Context, input ClearBucketInput) error
	ListBucketNamesFilteredByKeyword(ctx context.Context, keyword *string) ([]ListBucketNamesFilteredByKeywordOutput, error)
	CheckAllBucketsExist(ctx context.Context, bucketNames []string) ([]string, error)
}

func CreateS3Wrapper

func CreateS3Wrapper(config aws.Config, tableBucketsMode bool, directoryBucketsMode bool) IWrapper

type ListBucketNamesFilteredByKeywordOutput

type ListBucketNamesFilteredByKeywordOutput struct {
	BucketName   string
	TargetBucket string // bucket name for S3, bucket arn for S3Tables
}

type S3TablesWrapper

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

func NewS3TablesWrapper

func NewS3TablesWrapper(client client.IS3Tables) *S3TablesWrapper

func (*S3TablesWrapper) CheckAllBucketsExist

func (s *S3TablesWrapper) CheckAllBucketsExist(ctx context.Context, bucketNames []string) ([]string, error)

func (*S3TablesWrapper) ClearBucket

func (s *S3TablesWrapper) ClearBucket(
	ctx context.Context,
	input ClearBucketInput,
) error

func (*S3TablesWrapper) ListBucketNamesFilteredByKeyword

func (s *S3TablesWrapper) ListBucketNamesFilteredByKeyword(ctx context.Context, keyword *string) ([]ListBucketNamesFilteredByKeywordOutput, error)

type S3Wrapper

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

func NewS3Wrapper

func NewS3Wrapper(client client.IS3) *S3Wrapper

func (*S3Wrapper) CheckAllBucketsExist

func (s *S3Wrapper) CheckAllBucketsExist(ctx context.Context, bucketNames []string) ([]string, error)

func (*S3Wrapper) ClearBucket

func (s *S3Wrapper) ClearBucket(
	ctx context.Context,
	input ClearBucketInput,
) error

func (*S3Wrapper) ListBucketNamesFilteredByKeyword

func (s *S3Wrapper) ListBucketNamesFilteredByKeyword(ctx context.Context, keyword *string) ([]ListBucketNamesFilteredByKeywordOutput, error)