wrapper

package
v0.25.2 Latest Latest
Warning

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

 Go to latest Published: Feb 7, 2025 License: MIT Imports: 14 Imported by: 0

Documentation

Overview

Code generated by MockGen. DO NOT EDIT. Source: wrapper.go

Generated by this command: 

mockgen -source=wrapper.go -destination=mock_wrapper.go -package=wrapper -write_package_comment=false

Index

Constants

View Source 
const SDKRetryMaxAttempts = 3
View Source 
const SemaphoreWeight = 4

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
	ClearingCountCh chan int64
}

type CreateS3WrapperInput added in v0.25.1 

type CreateS3WrapperInput struct {
	Region               string
	Profile              string
	TableBucketsMode     bool
	DirectoryBucketsMode bool
}

type IWrapper added in v0.23.0 

type IWrapper interface {
	ClearBucket(ctx context.Context, input ClearBucketInput) error
	OutputClearedMessage(bucket string, count int64) error
	OutputDeletedMessage(bucket string) error
	OutputCheckingMessage(bucket string) error
	GetLiveClearingMessage(bucket string, count int64) (string, error)
	GetLiveClearedMessage(bucket string, count int64, isCompleted bool) (string, 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(ctx context.Context, input CreateS3WrapperInput) (IWrapper, error)

type ListBucketNamesFilteredByKeywordOutput added in v0.23.0 

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

type MockIWrapper added in v0.25.0 

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

MockIWrapper is a mock of IWrapper interface.

func NewMockIWrapper added in v0.25.0 

func NewMockIWrapper(ctrl *gomock.Controller) *MockIWrapper

NewMockIWrapper creates a new mock instance.

func (*MockIWrapper) CheckAllBucketsExist added in v0.25.0 

func (m *MockIWrapper) CheckAllBucketsExist(ctx context.Context, bucketNames []string) ([]string, error)

CheckAllBucketsExist mocks base method.

func (*MockIWrapper) ClearBucket added in v0.25.0 

func (m *MockIWrapper) ClearBucket(ctx context.Context, input ClearBucketInput) error

ClearBucket mocks base method.

func (*MockIWrapper) EXPECT added in v0.25.0 

func (m *MockIWrapper) EXPECT() *MockIWrapperMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockIWrapper) GetLiveClearedMessage added in v0.25.0 

func (m *MockIWrapper) GetLiveClearedMessage(bucket string, count int64, isCompleted bool) (string, error)

GetLiveClearedMessage mocks base method.

func (*MockIWrapper) GetLiveClearingMessage added in v0.25.0 

func (m *MockIWrapper) GetLiveClearingMessage(bucket string, count int64) (string, error)

GetLiveClearingMessage mocks base method.

func (*MockIWrapper) ListBucketNamesFilteredByKeyword added in v0.25.0 

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

ListBucketNamesFilteredByKeyword mocks base method.

func (*MockIWrapper) OutputCheckingMessage added in v0.25.0 

func (m *MockIWrapper) OutputCheckingMessage(bucket string) error

OutputCheckingMessage mocks base method.

func (*MockIWrapper) OutputClearedMessage added in v0.25.0 

func (m *MockIWrapper) OutputClearedMessage(bucket string, count int64) error

OutputClearedMessage mocks base method.

func (*MockIWrapper) OutputDeletedMessage added in v0.25.0 

func (m *MockIWrapper) OutputDeletedMessage(bucket string) error

OutputDeletedMessage mocks base method.

type MockIWrapperMockRecorder added in v0.25.0 

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

MockIWrapperMockRecorder is the mock recorder for MockIWrapper.

func (*MockIWrapperMockRecorder) CheckAllBucketsExist added in v0.25.0 

func (mr *MockIWrapperMockRecorder) CheckAllBucketsExist(ctx, bucketNames any) *gomock.Call

CheckAllBucketsExist indicates an expected call of CheckAllBucketsExist.

func (*MockIWrapperMockRecorder) ClearBucket added in v0.25.0 

func (mr *MockIWrapperMockRecorder) ClearBucket(ctx, input any) *gomock.Call

ClearBucket indicates an expected call of ClearBucket.

func (*MockIWrapperMockRecorder) GetLiveClearedMessage added in v0.25.0 

func (mr *MockIWrapperMockRecorder) GetLiveClearedMessage(bucket, count, isCompleted any) *gomock.Call

GetLiveClearedMessage indicates an expected call of GetLiveClearedMessage.

func (*MockIWrapperMockRecorder) GetLiveClearingMessage added in v0.25.0 

func (mr *MockIWrapperMockRecorder) GetLiveClearingMessage(bucket, count any) *gomock.Call

GetLiveClearingMessage indicates an expected call of GetLiveClearingMessage.

func (*MockIWrapperMockRecorder) ListBucketNamesFilteredByKeyword added in v0.25.0 

func (mr *MockIWrapperMockRecorder) ListBucketNamesFilteredByKeyword(ctx, keyword any) *gomock.Call

ListBucketNamesFilteredByKeyword indicates an expected call of ListBucketNamesFilteredByKeyword.

func (*MockIWrapperMockRecorder) OutputCheckingMessage added in v0.25.0 

func (mr *MockIWrapperMockRecorder) OutputCheckingMessage(bucket any) *gomock.Call

OutputCheckingMessage indicates an expected call of OutputCheckingMessage.

func (*MockIWrapperMockRecorder) OutputClearedMessage added in v0.25.0 

func (mr *MockIWrapperMockRecorder) OutputClearedMessage(bucket, count any) *gomock.Call

OutputClearedMessage indicates an expected call of OutputClearedMessage.

func (*MockIWrapperMockRecorder) OutputDeletedMessage added in v0.25.0 

func (mr *MockIWrapperMockRecorder) OutputDeletedMessage(bucket any) *gomock.Call

OutputDeletedMessage indicates an expected call of OutputDeletedMessage.

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) GetLiveClearedMessage added in v0.25.0 

func (s *S3TablesWrapper) GetLiveClearedMessage(bucket string, count int64, isCompleted bool) (string, error)

func (*S3TablesWrapper) GetLiveClearingMessage added in v0.25.0 

func (s *S3TablesWrapper) GetLiveClearingMessage(bucket string, count int64) (string, error)

func (*S3TablesWrapper) ListBucketNamesFilteredByKeyword added in v0.23.0 

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

func (*S3TablesWrapper) OutputCheckingMessage added in v0.25.0 

func (s *S3TablesWrapper) OutputCheckingMessage(bucket string) error

func (*S3TablesWrapper) OutputClearedMessage added in v0.25.0 

func (s *S3TablesWrapper) OutputClearedMessage(bucket string, count int64) error

func (*S3TablesWrapper) OutputDeletedMessage added in v0.25.0 

func (s *S3TablesWrapper) OutputDeletedMessage(bucket string) 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) GetLiveClearedMessage added in v0.25.0 

func (s *S3Wrapper) GetLiveClearedMessage(bucket string, count int64, isCompleted bool) (string, error)

func (*S3Wrapper) GetLiveClearingMessage added in v0.25.0 

func (s *S3Wrapper) GetLiveClearingMessage(bucket string, count int64) (string, error)

func (*S3Wrapper) ListBucketNamesFilteredByKeyword 

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

func (*S3Wrapper) OutputCheckingMessage added in v0.25.0 

func (s *S3Wrapper) OutputCheckingMessage(bucket string) error

func (*S3Wrapper) OutputClearedMessage added in v0.25.0 

func (s *S3Wrapper) OutputClearedMessage(bucket string, count int64) error

func (*S3Wrapper) OutputDeletedMessage added in v0.25.0 

func (s *S3Wrapper) OutputDeletedMessage(bucket string) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.