client

package
v0.24.1 Latest Latest
Warning

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

 Go to latest Published: Jan 22, 2025 License: MIT Imports: 14 Imported by: 0

Documentation

Overview

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

Generated by this command: 

mockgen -source=s3.go -destination=s3_mock.go -package=client -write_package_comment=false

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

Generated by this command: 

mockgen -source=s3_tables.go -destination=s3_tables_mock.go -package=client -write_package_comment=false

Index

Constants

View Source 
const DefaultAwsRegion = "ap-northeast-1"

TODO: change to us-east-1 (and README and blogs)

View Source 
const MaxRetryCount = 10

Variables

View Source 
var SleepTimeSecForS3 = 10
View Source 
var SleepTimeSecForS3Tables = 3

Functions

func LoadAWSConfig 

func LoadAWSConfig(ctx context.Context, region string, profile string) (aws.Config, error)

Types

type ClientError 

type ClientError struct {
	ResourceName *string
	Err          error
}

ClientError provides the error with a resource name

func (*ClientError) Error 

func (e *ClientError) Error() string

func (*ClientError) Unwrap 

func (e *ClientError) Unwrap() error

type IS3 

type IS3 interface {
	DeleteBucket(ctx context.Context, bucketName *string, region string) error
	DeleteObjects(
		ctx context.Context,
		bucketName *string,
		objects []types.ObjectIdentifier,
		region string,
	) ([]types.Error, error)
	ListObjectsOrVersionsByPage(
		ctx context.Context,
		bucketName *string,
		region string,
		oldVersionsOnly bool,
		keyMarker *string,
		versionIdMarker *string,
	) (*ListObjectsOrVersionsByPageOutput, error)
	ListBucketsOrDirectoryBuckets(ctx context.Context) ([]types.Bucket, error)
	GetBucketLocation(ctx context.Context, bucketName *string) (string, error)
}

type IS3Tables added in v0.23.0 

type IS3Tables interface {
	DeleteTableBucket(ctx context.Context, tableBucketARN *string) error
	DeleteNamespace(ctx context.Context, namespace *string, tableBucketARN *string) error
	DeleteTable(ctx context.Context, tableName *string, namespace *string, tableBucketARN *string) error
	ListTableBuckets(ctx context.Context) ([]types.TableBucketSummary, error)
	ListNamespacesByPage(ctx context.Context, tableBucketARN *string, continuationToken *string) (*ListNamespacesByPageOutput, error)
	ListTablesByPage(ctx context.Context, tableBucketARN *string, namespace *string, continuationToken *string) (*ListTablesByPageOutput, error)
}

type ListNamespacesByPageOutput added in v0.23.0 

type ListNamespacesByPageOutput struct {
	Namespaces        []types.NamespaceSummary
	ContinuationToken *string
}

type ListObjectsOrVersionsByPageOutput added in v0.20.1 

type ListObjectsOrVersionsByPageOutput struct {
	ObjectIdentifiers   []types.ObjectIdentifier
	NextKeyMarker       *string
	NextVersionIdMarker *string
}

type ListTablesByPageOutput added in v0.23.0 

type ListTablesByPageOutput struct {
	Tables            []types.TableSummary
	ContinuationToken *string
}

type MockIS3 

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

MockIS3 is a mock of IS3 interface.

func NewMockIS3 

func NewMockIS3(ctrl *gomock.Controller) *MockIS3

NewMockIS3 creates a new mock instance.

func (*MockIS3) DeleteBucket 

func (m *MockIS3) DeleteBucket(ctx context.Context, bucketName *string, region string) error

DeleteBucket mocks base method.

func (*MockIS3) DeleteObjects 

func (m *MockIS3) DeleteObjects(ctx context.Context, bucketName *string, objects []types.ObjectIdentifier, region string) ([]types.Error, error)

DeleteObjects mocks base method.

func (*MockIS3) EXPECT 

func (m *MockIS3) EXPECT() *MockIS3MockRecorder

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

func (*MockIS3) GetBucketLocation added in v0.7.0 

func (m *MockIS3) GetBucketLocation(ctx context.Context, bucketName *string) (string, error)

GetBucketLocation mocks base method.

func (*MockIS3) ListBucketsOrDirectoryBuckets added in v0.22.0 

func (m *MockIS3) ListBucketsOrDirectoryBuckets(ctx context.Context) ([]types.Bucket, error)

ListBucketsOrDirectoryBuckets mocks base method.

func (*MockIS3) ListObjectsOrVersionsByPage added in v0.20.1 

func (m *MockIS3) ListObjectsOrVersionsByPage(ctx context.Context, bucketName *string, region string, oldVersionsOnly bool, keyMarker, versionIdMarker *string) (*ListObjectsOrVersionsByPageOutput, error)

ListObjectsOrVersionsByPage mocks base method.

type MockIS3MockRecorder 

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

MockIS3MockRecorder is the mock recorder for MockIS3.

func (*MockIS3MockRecorder) DeleteBucket 

func (mr *MockIS3MockRecorder) DeleteBucket(ctx, bucketName, region any) *gomock.Call

DeleteBucket indicates an expected call of DeleteBucket.

func (*MockIS3MockRecorder) DeleteObjects 

func (mr *MockIS3MockRecorder) DeleteObjects(ctx, bucketName, objects, region any) *gomock.Call

DeleteObjects indicates an expected call of DeleteObjects.

func (*MockIS3MockRecorder) GetBucketLocation added in v0.7.0 

func (mr *MockIS3MockRecorder) GetBucketLocation(ctx, bucketName any) *gomock.Call

GetBucketLocation indicates an expected call of GetBucketLocation.

func (*MockIS3MockRecorder) ListBucketsOrDirectoryBuckets added in v0.22.0 

func (mr *MockIS3MockRecorder) ListBucketsOrDirectoryBuckets(ctx any) *gomock.Call

ListBucketsOrDirectoryBuckets indicates an expected call of ListBucketsOrDirectoryBuckets.

func (*MockIS3MockRecorder) ListObjectsOrVersionsByPage added in v0.20.1 

func (mr *MockIS3MockRecorder) ListObjectsOrVersionsByPage(ctx, bucketName, region, oldVersionsOnly, keyMarker, versionIdMarker any) *gomock.Call

ListObjectsOrVersionsByPage indicates an expected call of ListObjectsOrVersionsByPage.

type MockIS3Tables added in v0.23.0 

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

MockIS3Tables is a mock of IS3Tables interface.

func NewMockIS3Tables added in v0.23.0 

func NewMockIS3Tables(ctrl *gomock.Controller) *MockIS3Tables

NewMockIS3Tables creates a new mock instance.

func (*MockIS3Tables) DeleteNamespace added in v0.23.0 

func (m *MockIS3Tables) DeleteNamespace(ctx context.Context, namespace, tableBucketARN *string) error

DeleteNamespace mocks base method.

func (*MockIS3Tables) DeleteTable added in v0.23.0 

func (m *MockIS3Tables) DeleteTable(ctx context.Context, tableName, namespace, tableBucketARN *string) error

DeleteTable mocks base method.

func (*MockIS3Tables) DeleteTableBucket added in v0.23.0 

func (m *MockIS3Tables) DeleteTableBucket(ctx context.Context, tableBucketARN *string) error

DeleteTableBucket mocks base method.

func (*MockIS3Tables) EXPECT added in v0.23.0 

func (m *MockIS3Tables) EXPECT() *MockIS3TablesMockRecorder

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

func (*MockIS3Tables) ListNamespacesByPage added in v0.23.0 

func (m *MockIS3Tables) ListNamespacesByPage(ctx context.Context, tableBucketARN, continuationToken *string) (*ListNamespacesByPageOutput, error)

ListNamespacesByPage mocks base method.

func (*MockIS3Tables) ListTableBuckets added in v0.23.0 

func (m *MockIS3Tables) ListTableBuckets(ctx context.Context) ([]types.TableBucketSummary, error)

ListTableBuckets mocks base method.

func (*MockIS3Tables) ListTablesByPage added in v0.23.0 

func (m *MockIS3Tables) ListTablesByPage(ctx context.Context, tableBucketARN, namespace, continuationToken *string) (*ListTablesByPageOutput, error)

ListTablesByPage mocks base method.

type MockIS3TablesMockRecorder added in v0.23.0 

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

MockIS3TablesMockRecorder is the mock recorder for MockIS3Tables.

func (*MockIS3TablesMockRecorder) DeleteNamespace added in v0.23.0 

func (mr *MockIS3TablesMockRecorder) DeleteNamespace(ctx, namespace, tableBucketARN any) *gomock.Call

DeleteNamespace indicates an expected call of DeleteNamespace.

func (*MockIS3TablesMockRecorder) DeleteTable added in v0.23.0 

func (mr *MockIS3TablesMockRecorder) DeleteTable(ctx, tableName, namespace, tableBucketARN any) *gomock.Call

DeleteTable indicates an expected call of DeleteTable.

func (*MockIS3TablesMockRecorder) DeleteTableBucket added in v0.23.0 

func (mr *MockIS3TablesMockRecorder) DeleteTableBucket(ctx, tableBucketARN any) *gomock.Call

DeleteTableBucket indicates an expected call of DeleteTableBucket.

func (*MockIS3TablesMockRecorder) ListNamespacesByPage added in v0.23.0 

func (mr *MockIS3TablesMockRecorder) ListNamespacesByPage(ctx, tableBucketARN, continuationToken any) *gomock.Call

ListNamespacesByPage indicates an expected call of ListNamespacesByPage.

func (*MockIS3TablesMockRecorder) ListTableBuckets added in v0.23.0 

func (mr *MockIS3TablesMockRecorder) ListTableBuckets(ctx any) *gomock.Call

ListTableBuckets indicates an expected call of ListTableBuckets.

func (*MockIS3TablesMockRecorder) ListTablesByPage added in v0.23.0 

func (mr *MockIS3TablesMockRecorder) ListTablesByPage(ctx, tableBucketARN, namespace, continuationToken any) *gomock.Call

ListTablesByPage indicates an expected call of ListTablesByPage.

type Retryer 

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

func NewRetryer 

func NewRetryer(isErrorRetryableFunc func(error) bool, delayTimeSec int) *Retryer

func (*Retryer) GetAttemptToken 

func (r *Retryer) GetAttemptToken(context.Context) (func(error) error, error)

func (*Retryer) GetInitialToken 

func (r *Retryer) GetInitialToken() func(error) error

func (*Retryer) GetRetryToken 

func (r *Retryer) GetRetryToken(context.Context, error) (func(error) error, error)

func (*Retryer) IsErrorRetryable 

func (r *Retryer) IsErrorRetryable(err error) bool

func (*Retryer) MaxAttempts 

func (r *Retryer) MaxAttempts() int

func (*Retryer) RetryDelay 

func (r *Retryer) RetryDelay(int, error) (time.Duration, error)

type S3 

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

func NewS3 

func NewS3(client *s3.Client, directoryBucketsMode bool) *S3

func (*S3) DeleteBucket 

func (s *S3) DeleteBucket(ctx context.Context, bucketName *string, region string) error

func (*S3) DeleteObjects 

func (s *S3) DeleteObjects(
	ctx context.Context,
	bucketName *string,
	objects []types.ObjectIdentifier,
	region string,
) ([]types.Error, error)

func (*S3) GetBucketLocation added in v0.7.0 

func (s *S3) GetBucketLocation(ctx context.Context, bucketName *string) (string, error)

func (*S3) ListBucketsOrDirectoryBuckets added in v0.22.0 

func (s *S3) ListBucketsOrDirectoryBuckets(ctx context.Context) ([]types.Bucket, error)

func (*S3) ListObjectsOrVersionsByPage added in v0.20.1 

func (s *S3) ListObjectsOrVersionsByPage(
	ctx context.Context,
	bucketName *string,
	region string,
	oldVersionsOnly bool,
	keyMarker *string,
	versionIdMarker *string,
) (*ListObjectsOrVersionsByPageOutput, error)

type S3Tables added in v0.23.0 

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

func NewS3Tables added in v0.23.0 

func NewS3Tables(client *s3tables.Client) *S3Tables

func (*S3Tables) DeleteNamespace added in v0.23.0 

func (s *S3Tables) DeleteNamespace(ctx context.Context, namespace *string, tableBucketARN *string) error

func (*S3Tables) DeleteTable added in v0.23.0 

func (s *S3Tables) DeleteTable(ctx context.Context, tableName *string, namespace *string, tableBucketARN *string) error

func (*S3Tables) DeleteTableBucket added in v0.23.0 

func (s *S3Tables) DeleteTableBucket(ctx context.Context, tableBucketARN *string) error

func (*S3Tables) ListNamespacesByPage added in v0.23.0 

func (s *S3Tables) ListNamespacesByPage(ctx context.Context, tableBucketARN *string, continuationToken *string) (*ListNamespacesByPageOutput, error)

func (*S3Tables) ListTableBuckets added in v0.23.0 

func (s *S3Tables) ListTableBuckets(ctx context.Context) ([]types.TableBucketSummary, error)

func (*S3Tables) ListTablesByPage added in v0.23.0 

func (s *S3Tables) ListTablesByPage(ctx context.Context, tableBucketARN *string, namespace *string, continuationToken *string) (*ListTablesByPageOutput, 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.