wrapper

package
v0.23.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 20, 2025 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const SDKRetryMaxAttempts = 3
View Source
const SemaphoreWeight = 5

Too Many Requests error often occurs, so limit the value

Variables

This section is empty.

Functions

This section is empty.

Types

type ClearBucketInput added in v0.23.0

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

type IWrapper added in v0.23.0

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 added in v0.23.0

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

type ListBucketNamesFilteredByKeywordOutput added in v0.23.0

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

type S3TablesWrapper added in v0.23.0

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

func NewS3TablesWrapper added in v0.23.0

func NewS3TablesWrapper(client client.IS3Tables) *S3TablesWrapper

func (*S3TablesWrapper) CheckAllBucketsExist added in v0.23.0

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

func (*S3TablesWrapper) ClearBucket added in v0.23.0

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

func (*S3TablesWrapper) ListBucketNamesFilteredByKeyword added in v0.23.0

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 added in v0.22.0

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

func (*S3Wrapper) ClearBucket added in v0.23.0

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

func (*S3Wrapper) ListBucketNamesFilteredByKeyword

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL