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
- type ClearBucketInput
- type CreateS3WrapperInput
- type IWrapper
- type ListBucketNamesFilteredByKeywordOutput
- type MockIWrapper
- func (m *MockIWrapper) CheckAllBucketsExist(ctx context.Context, bucketNames []string) ([]string, error)
- func (m *MockIWrapper) ClearBucket(ctx context.Context, input ClearBucketInput) error
- func (m *MockIWrapper) EXPECT() *MockIWrapperMockRecorder
- func (m *MockIWrapper) GetLiveClearedMessage(bucket string, count int64, isCompleted bool) (string, error)
- func (m *MockIWrapper) GetLiveClearingMessage(bucket string, count int64) (string, error)
- func (m *MockIWrapper) ListBucketNamesFilteredByKeyword(ctx context.Context, keyword *string) ([]ListBucketNamesFilteredByKeywordOutput, error)
- func (m *MockIWrapper) OutputCheckingMessage(bucket string) error
- func (m *MockIWrapper) OutputClearedMessage(bucket string, count int64) error
- func (m *MockIWrapper) OutputDeletedMessage(bucket string) error
- type MockIWrapperMockRecorder
- func (mr *MockIWrapperMockRecorder) CheckAllBucketsExist(ctx, bucketNames any) *gomock.Call
- func (mr *MockIWrapperMockRecorder) ClearBucket(ctx, input any) *gomock.Call
- func (mr *MockIWrapperMockRecorder) GetLiveClearedMessage(bucket, count, isCompleted any) *gomock.Call
- func (mr *MockIWrapperMockRecorder) GetLiveClearingMessage(bucket, count any) *gomock.Call
- func (mr *MockIWrapperMockRecorder) ListBucketNamesFilteredByKeyword(ctx, keyword any) *gomock.Call
- func (mr *MockIWrapperMockRecorder) OutputCheckingMessage(bucket any) *gomock.Call
- func (mr *MockIWrapperMockRecorder) OutputClearedMessage(bucket, count any) *gomock.Call
- func (mr *MockIWrapperMockRecorder) OutputDeletedMessage(bucket any) *gomock.Call
- type 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) GetLiveClearedMessage(bucket string, count int64, isCompleted bool) (string, error)
- func (s *S3TablesWrapper) GetLiveClearingMessage(bucket string, count int64) (string, error)
- func (s *S3TablesWrapper) ListBucketNamesFilteredByKeyword(ctx context.Context, keyword *string) ([]ListBucketNamesFilteredByKeywordOutput, error)
- func (s *S3TablesWrapper) OutputCheckingMessage(bucket string) error
- func (s *S3TablesWrapper) OutputClearedMessage(bucket string, count int64) error
- func (s *S3TablesWrapper) OutputDeletedMessage(bucket string) error
- type 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) GetLiveClearedMessage(bucket string, count int64, isCompleted bool) (string, error)
- func (s *S3Wrapper) GetLiveClearingMessage(bucket string, count int64) (string, error)
- func (s *S3Wrapper) ListBucketNamesFilteredByKeyword(ctx context.Context, keyword *string) ([]ListBucketNamesFilteredByKeywordOutput, error)
- func (s *S3Wrapper) OutputCheckingMessage(bucket string) error
- func (s *S3Wrapper) OutputClearedMessage(bucket string, count int64) error
- func (s *S3Wrapper) OutputDeletedMessage(bucket string) error
Constants ¶
const SDKRetryMaxAttempts = 3
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 CreateS3WrapperInput ¶ added in v0.25.1
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 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 (*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 (*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 (*S3Wrapper) CheckAllBucketsExist ¶ added in v0.22.0
func (*S3Wrapper) ClearBucket ¶ added in v0.23.0
func (s *S3Wrapper) ClearBucket( ctx context.Context, input ClearBucketInput, ) error