client

package
v1.17.0 Latest Latest
Warning

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

 Go to latest Published: Nov 7, 2025 License: MIT Imports: 22 Imported by: 1

Documentation

Overview

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

Generated by this command: 

mockgen -source=backup.go -destination=backup_mock.go -package=client -write_package_comment=false

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

Generated by this command: 

mockgen -source=cloudformation.go -destination=cloudformation_mock.go -package=client -write_package_comment=false

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

Generated by this command: 

mockgen -source=ecr.go -destination=ecr_mock.go -package=client -write_package_comment=false

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

Generated by this command: 

mockgen -source=iam.go -destination=iam_mock.go -package=client -write_package_comment=false

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

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

Generated by this command: 

mockgen -source=s3_vectors.go -destination=s3_vectors_mock.go -package=client -write_package_comment=false

Index

Constants

View Source 
const CloudFormationWaitNanoSecTime = time.Duration(4500000000000)
View Source 
const DefaultAwsRegion = "us-east-1"
View Source 
const MaxRetryCount = 10

Variables

View Source 
var SleepTimeSecForIam = 5
View Source 
var SleepTimeSecForS3 = 10
View Source 
var SleepTimeSecForS3Tables = 3 // NOTE: Because S3Tables is a serial operation, a low value is OK.
View Source 
var SleepTimeSecForS3Vectors = 20

Functions

func LoadAWSConfig added in v0.7.0 

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

Types

type Backup 

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

func NewBackup 

func NewBackup(client *backup.Client) *Backup

func (*Backup) CheckBackupVaultExists 

func (b *Backup) CheckBackupVaultExists(ctx context.Context, backupVaultName *string) (bool, error)

func (*Backup) DeleteBackupVault 

func (b *Backup) DeleteBackupVault(ctx context.Context, backupVaultName *string) error

func (*Backup) DeleteRecoveryPoints 

func (b *Backup) DeleteRecoveryPoints(ctx context.Context, backupVaultName *string, recoveryPoints []types.RecoveryPointByBackupVault) error

func (*Backup) ListRecoveryPointsByBackupVault 

func (b *Backup) ListRecoveryPointsByBackupVault(ctx context.Context, backupVaultName *string) ([]types.RecoveryPointByBackupVault, error)

type ClientError added in v0.10.0 

type ClientError struct {
	ResourceName *string
	Err          error
}

ClientError provides the error with a resource name

func (*ClientError) Error added in v0.10.0 

func (e *ClientError) Error() string

func (*ClientError) Unwrap added in v0.10.0 

func (e *ClientError) Unwrap() error

type CloudFormation 

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

func NewCloudFormation 

func NewCloudFormation(client *cloudformation.Client, deleteCompleteWaiter *cloudformation.StackDeleteCompleteWaiter, updateCompleteWaiter *cloudformation.StackUpdateCompleteWaiter) *CloudFormation

func (*CloudFormation) DeleteStack 

func (c *CloudFormation) DeleteStack(ctx context.Context, stackName *string, retainResources []string) error

func (*CloudFormation) DescribeStacks 

func (c *CloudFormation) DescribeStacks(ctx context.Context, stackName *string) ([]types.Stack, error)

func (*CloudFormation) GetTemplate added in v1.16.0 

func (c *CloudFormation) GetTemplate(ctx context.Context, stackName *string) (*string, error)

func (*CloudFormation) ListStackResources 

func (c *CloudFormation) ListStackResources(ctx context.Context, stackName *string) ([]types.StackResourceSummary, error)

func (*CloudFormation) UpdateStack added in v1.16.0 

func (c *CloudFormation) UpdateStack(ctx context.Context, stackName *string, templateBody *string, parameters []types.Parameter) error

type Ecr 

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

func NewEcr 

func NewEcr(client *ecr.Client) *Ecr

func (*Ecr) CheckEcrExists 

func (e *Ecr) CheckEcrExists(ctx context.Context, repositoryName *string) (bool, error)

func (*Ecr) DeleteRepository 

func (e *Ecr) DeleteRepository(ctx context.Context, repositoryName *string) error

type IBackup 

type IBackup interface {
	ListRecoveryPointsByBackupVault(ctx context.Context, backupVaultName *string) ([]types.RecoveryPointByBackupVault, error)
	DeleteRecoveryPoints(ctx context.Context, backupVaultName *string, recoveryPoints []types.RecoveryPointByBackupVault) error
	DeleteBackupVault(ctx context.Context, backupVaultName *string) error
	CheckBackupVaultExists(ctx context.Context, backupVaultName *string) (bool, error)
}

type ICloudFormation 

type ICloudFormation interface {
	DeleteStack(ctx context.Context, stackName *string, retainResources []string) error
	DescribeStacks(ctx context.Context, stackName *string) ([]types.Stack, error)
	ListStackResources(ctx context.Context, stackName *string) ([]types.StackResourceSummary, error)
	GetTemplate(ctx context.Context, stackName *string) (*string, error)
	UpdateStack(ctx context.Context, stackName *string, templateBody *string, parameters []types.Parameter) error
}

type IEcr 

type IEcr interface {
	DeleteRepository(ctx context.Context, repositoryName *string) error
	CheckEcrExists(ctx context.Context, repositoryName *string) (bool, error)
}

type IIam 

type IIam interface {
	DeleteGroup(ctx context.Context, groupName *string) error
	CheckGroupExists(ctx context.Context, groupName *string) (bool, error)
	GetGroupUsers(ctx context.Context, groupName *string) ([]types.User, error)
	RemoveUsersFromGroup(ctx context.Context, groupName *string, users []types.User) error
}

type IS3 

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

type IS3Tables added in v1.15.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
	ListNamespacesByPage(ctx context.Context, tableBucketARN *string, continuationToken *string) (*ListNamespacesByPageOutput, error)
	ListTablesByPage(ctx context.Context, tableBucketARN *string, namespace *string, continuationToken *string) (*ListTablesByPageOutput, error)
	CheckTableBucketExists(ctx context.Context, tableBucketName *string) (bool, error)
	CheckNamespaceExists(ctx context.Context, tableBucketARN *string, namespace *string) (bool, error)
}

type IS3Vectors added in v1.17.0 

type IS3Vectors interface {
	DeleteVectorBucket(ctx context.Context, vectorBucketName *string) error
	DeleteIndex(ctx context.Context, indexName *string, vectorBucketName *string) error
	ListIndexesByPage(ctx context.Context, vectorBucketName *string, nextToken *string, keyPrefix *string) (*ListIndexesByPageOutput, error)
	CheckVectorBucketExists(ctx context.Context, vectorBucketName *string) (bool, error)
}

type Iam 

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

func NewIam 

func NewIam(client *iam.Client) *Iam

func (*Iam) CheckGroupExists added in v1.12.0 

func (i *Iam) CheckGroupExists(ctx context.Context, groupName *string) (bool, error)

func (*Iam) DeleteGroup added in v1.12.0 

func (i *Iam) DeleteGroup(ctx context.Context, groupName *string) error

func (*Iam) GetGroupUsers added in v1.12.0 

func (i *Iam) GetGroupUsers(ctx context.Context, groupName *string) ([]types.User, error)

func (*Iam) RemoveUsersFromGroup added in v1.12.0 

func (i *Iam) RemoveUsersFromGroup(ctx context.Context, groupName *string, users []types.User) error

type ListIndexesByPageOutput added in v1.17.0 

type ListIndexesByPageOutput struct {
	Indexes   []types.IndexSummary
	NextToken *string
}

type ListNamespacesByPageOutput added in v1.15.0 

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

type ListObjectsOrVersionsByPageOutput added in v1.11.0 

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

type ListTablesByPageOutput added in v1.15.0 

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

type MockIBackup added in v0.9.0 

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

MockIBackup is a mock of IBackup interface.

func NewMockIBackup added in v0.9.0 

func NewMockIBackup(ctrl *gomock.Controller) *MockIBackup

NewMockIBackup creates a new mock instance.

func (*MockIBackup) CheckBackupVaultExists added in v0.9.0 

func (m *MockIBackup) CheckBackupVaultExists(ctx context.Context, backupVaultName *string) (bool, error)

CheckBackupVaultExists mocks base method.

func (*MockIBackup) DeleteBackupVault added in v0.9.0 

func (m *MockIBackup) DeleteBackupVault(ctx context.Context, backupVaultName *string) error

DeleteBackupVault mocks base method.

func (*MockIBackup) DeleteRecoveryPoints added in v0.9.0 

func (m *MockIBackup) DeleteRecoveryPoints(ctx context.Context, backupVaultName *string, recoveryPoints []types.RecoveryPointByBackupVault) error

DeleteRecoveryPoints mocks base method.

func (*MockIBackup) EXPECT added in v0.9.0 

func (m *MockIBackup) EXPECT() *MockIBackupMockRecorder

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

func (*MockIBackup) ListRecoveryPointsByBackupVault added in v0.9.0 

func (m *MockIBackup) ListRecoveryPointsByBackupVault(ctx context.Context, backupVaultName *string) ([]types.RecoveryPointByBackupVault, error)

ListRecoveryPointsByBackupVault mocks base method.

type MockIBackupMockRecorder added in v0.9.0 

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

MockIBackupMockRecorder is the mock recorder for MockIBackup.

func (*MockIBackupMockRecorder) CheckBackupVaultExists added in v0.9.0 

func (mr *MockIBackupMockRecorder) CheckBackupVaultExists(ctx, backupVaultName any) *gomock.Call

CheckBackupVaultExists indicates an expected call of CheckBackupVaultExists.

func (*MockIBackupMockRecorder) DeleteBackupVault added in v0.9.0 

func (mr *MockIBackupMockRecorder) DeleteBackupVault(ctx, backupVaultName any) *gomock.Call

DeleteBackupVault indicates an expected call of DeleteBackupVault.

func (*MockIBackupMockRecorder) DeleteRecoveryPoints added in v0.9.0 

func (mr *MockIBackupMockRecorder) DeleteRecoveryPoints(ctx, backupVaultName, recoveryPoints any) *gomock.Call

DeleteRecoveryPoints indicates an expected call of DeleteRecoveryPoints.

func (*MockIBackupMockRecorder) ListRecoveryPointsByBackupVault added in v0.9.0 

func (mr *MockIBackupMockRecorder) ListRecoveryPointsByBackupVault(ctx, backupVaultName any) *gomock.Call

ListRecoveryPointsByBackupVault indicates an expected call of ListRecoveryPointsByBackupVault.

type MockICloudFormation added in v0.9.0 

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

MockICloudFormation is a mock of ICloudFormation interface.

func NewMockICloudFormation added in v0.9.0 

func NewMockICloudFormation(ctrl *gomock.Controller) *MockICloudFormation

NewMockICloudFormation creates a new mock instance.

func (*MockICloudFormation) DeleteStack added in v0.9.0 

func (m *MockICloudFormation) DeleteStack(ctx context.Context, stackName *string, retainResources []string) error

DeleteStack mocks base method.

func (*MockICloudFormation) DescribeStacks added in v0.9.0 

func (m *MockICloudFormation) DescribeStacks(ctx context.Context, stackName *string) ([]types.Stack, error)

DescribeStacks mocks base method.

func (*MockICloudFormation) EXPECT added in v0.9.0 

func (m *MockICloudFormation) EXPECT() *MockICloudFormationMockRecorder

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

func (*MockICloudFormation) GetTemplate added in v1.16.0 

func (m *MockICloudFormation) GetTemplate(ctx context.Context, stackName *string) (*string, error)

GetTemplate mocks base method.

func (*MockICloudFormation) ListStackResources added in v0.9.0 

func (m *MockICloudFormation) ListStackResources(ctx context.Context, stackName *string) ([]types.StackResourceSummary, error)

ListStackResources mocks base method.

func (*MockICloudFormation) UpdateStack added in v1.16.0 

func (m *MockICloudFormation) UpdateStack(ctx context.Context, stackName, templateBody *string, parameters []types.Parameter) error

UpdateStack mocks base method.

type MockICloudFormationMockRecorder added in v0.9.0 

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

MockICloudFormationMockRecorder is the mock recorder for MockICloudFormation.

func (*MockICloudFormationMockRecorder) DeleteStack added in v0.9.0 

func (mr *MockICloudFormationMockRecorder) DeleteStack(ctx, stackName, retainResources any) *gomock.Call

DeleteStack indicates an expected call of DeleteStack.

func (*MockICloudFormationMockRecorder) DescribeStacks added in v0.9.0 

func (mr *MockICloudFormationMockRecorder) DescribeStacks(ctx, stackName any) *gomock.Call

DescribeStacks indicates an expected call of DescribeStacks.

func (*MockICloudFormationMockRecorder) GetTemplate added in v1.16.0 

func (mr *MockICloudFormationMockRecorder) GetTemplate(ctx, stackName any) *gomock.Call

GetTemplate indicates an expected call of GetTemplate.

func (*MockICloudFormationMockRecorder) ListStackResources added in v0.9.0 

func (mr *MockICloudFormationMockRecorder) ListStackResources(ctx, stackName any) *gomock.Call

ListStackResources indicates an expected call of ListStackResources.

func (*MockICloudFormationMockRecorder) UpdateStack added in v1.16.0 

func (mr *MockICloudFormationMockRecorder) UpdateStack(ctx, stackName, templateBody, parameters any) *gomock.Call

UpdateStack indicates an expected call of UpdateStack.

type MockIEcr added in v0.9.0 

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

MockIEcr is a mock of IEcr interface.

func NewMockIEcr added in v0.9.0 

func NewMockIEcr(ctrl *gomock.Controller) *MockIEcr

NewMockIEcr creates a new mock instance.

func (*MockIEcr) CheckEcrExists added in v0.9.0 

func (m *MockIEcr) CheckEcrExists(ctx context.Context, repositoryName *string) (bool, error)

CheckEcrExists mocks base method.

func (*MockIEcr) DeleteRepository added in v0.9.0 

func (m *MockIEcr) DeleteRepository(ctx context.Context, repositoryName *string) error

DeleteRepository mocks base method.

func (*MockIEcr) EXPECT added in v0.9.0 

func (m *MockIEcr) EXPECT() *MockIEcrMockRecorder

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

type MockIEcrMockRecorder added in v0.9.0 

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

MockIEcrMockRecorder is the mock recorder for MockIEcr.

func (*MockIEcrMockRecorder) CheckEcrExists added in v0.9.0 

func (mr *MockIEcrMockRecorder) CheckEcrExists(ctx, repositoryName any) *gomock.Call

CheckEcrExists indicates an expected call of CheckEcrExists.

func (*MockIEcrMockRecorder) DeleteRepository added in v0.9.0 

func (mr *MockIEcrMockRecorder) DeleteRepository(ctx, repositoryName any) *gomock.Call

DeleteRepository indicates an expected call of DeleteRepository.

type MockIIam added in v0.9.0 

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

MockIIam is a mock of IIam interface.

func NewMockIIam added in v0.9.0 

func NewMockIIam(ctrl *gomock.Controller) *MockIIam

NewMockIIam creates a new mock instance.

func (*MockIIam) CheckGroupExists added in v1.12.0 

func (m *MockIIam) CheckGroupExists(ctx context.Context, groupName *string) (bool, error)

CheckGroupExists mocks base method.

func (*MockIIam) DeleteGroup added in v1.12.0 

func (m *MockIIam) DeleteGroup(ctx context.Context, groupName *string) error

DeleteGroup mocks base method.

func (*MockIIam) EXPECT added in v0.9.0 

func (m *MockIIam) EXPECT() *MockIIamMockRecorder

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

func (*MockIIam) GetGroupUsers added in v1.12.0 

func (m *MockIIam) GetGroupUsers(ctx context.Context, groupName *string) ([]types.User, error)

GetGroupUsers mocks base method.

func (*MockIIam) RemoveUsersFromGroup added in v1.12.0 

func (m *MockIIam) RemoveUsersFromGroup(ctx context.Context, groupName *string, users []types.User) error

RemoveUsersFromGroup mocks base method.

type MockIIamMockRecorder added in v0.9.0 

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

MockIIamMockRecorder is the mock recorder for MockIIam.

func (*MockIIamMockRecorder) CheckGroupExists added in v1.12.0 

func (mr *MockIIamMockRecorder) CheckGroupExists(ctx, groupName any) *gomock.Call

CheckGroupExists indicates an expected call of CheckGroupExists.

func (*MockIIamMockRecorder) DeleteGroup added in v1.12.0 

func (mr *MockIIamMockRecorder) DeleteGroup(ctx, groupName any) *gomock.Call

DeleteGroup indicates an expected call of DeleteGroup.

func (*MockIIamMockRecorder) GetGroupUsers added in v1.12.0 

func (mr *MockIIamMockRecorder) GetGroupUsers(ctx, groupName any) *gomock.Call

GetGroupUsers indicates an expected call of GetGroupUsers.

func (*MockIIamMockRecorder) RemoveUsersFromGroup added in v1.12.0 

func (mr *MockIIamMockRecorder) RemoveUsersFromGroup(ctx, groupName, users any) *gomock.Call

RemoveUsersFromGroup indicates an expected call of RemoveUsersFromGroup.

type MockIS3 added in v0.9.0 

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

MockIS3 is a mock of IS3 interface.

func NewMockIS3 added in v0.9.0 

func NewMockIS3(ctrl *gomock.Controller) *MockIS3

NewMockIS3 creates a new mock instance.

func (*MockIS3) CheckBucketExists added in v0.9.0 

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

CheckBucketExists mocks base method.

func (*MockIS3) DeleteBucket added in v0.9.0 

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

DeleteBucket mocks base method.

func (*MockIS3) DeleteObjects added in v0.9.0 

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

DeleteObjects mocks base method.

func (*MockIS3) EXPECT added in v0.9.0 

func (m *MockIS3) EXPECT() *MockIS3MockRecorder

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

func (*MockIS3) GetDirectoryBucketsFlag added in v1.11.0 

func (m *MockIS3) GetDirectoryBucketsFlag() bool

GetDirectoryBucketsFlag mocks base method.

func (*MockIS3) ListObjectsOrVersionsByPage added in v1.11.0 

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

ListObjectsOrVersionsByPage mocks base method.

type MockIS3MockRecorder added in v0.9.0 

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

MockIS3MockRecorder is the mock recorder for MockIS3.

func (*MockIS3MockRecorder) CheckBucketExists added in v0.9.0 

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

CheckBucketExists indicates an expected call of CheckBucketExists.

func (*MockIS3MockRecorder) DeleteBucket added in v0.9.0 

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

DeleteBucket indicates an expected call of DeleteBucket.

func (*MockIS3MockRecorder) DeleteObjects added in v0.9.0 

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

DeleteObjects indicates an expected call of DeleteObjects.

func (*MockIS3MockRecorder) GetDirectoryBucketsFlag added in v1.11.0 

func (mr *MockIS3MockRecorder) GetDirectoryBucketsFlag() *gomock.Call

GetDirectoryBucketsFlag indicates an expected call of GetDirectoryBucketsFlag.

func (*MockIS3MockRecorder) ListObjectsOrVersionsByPage added in v1.11.0 

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

ListObjectsOrVersionsByPage indicates an expected call of ListObjectsOrVersionsByPage.

type MockIS3Tables added in v1.15.0 

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

MockIS3Tables is a mock of IS3Tables interface.

func NewMockIS3Tables added in v1.15.0 

func NewMockIS3Tables(ctrl *gomock.Controller) *MockIS3Tables

NewMockIS3Tables creates a new mock instance.

func (*MockIS3Tables) CheckNamespaceExists added in v1.17.0 

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

CheckNamespaceExists mocks base method.

func (*MockIS3Tables) CheckTableBucketExists added in v1.15.0 

func (m *MockIS3Tables) CheckTableBucketExists(ctx context.Context, tableBucketName *string) (bool, error)

CheckTableBucketExists mocks base method.

func (*MockIS3Tables) DeleteNamespace added in v1.15.0 

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

DeleteNamespace mocks base method.

func (*MockIS3Tables) DeleteTable added in v1.15.0 

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

DeleteTable mocks base method.

func (*MockIS3Tables) DeleteTableBucket added in v1.15.0 

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

DeleteTableBucket mocks base method.

func (*MockIS3Tables) EXPECT added in v1.15.0 

func (m *MockIS3Tables) EXPECT() *MockIS3TablesMockRecorder

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

func (*MockIS3Tables) ListNamespacesByPage added in v1.15.0 

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

ListNamespacesByPage mocks base method.

func (*MockIS3Tables) ListTablesByPage added in v1.15.0 

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

ListTablesByPage mocks base method.

type MockIS3TablesMockRecorder added in v1.15.0 

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

MockIS3TablesMockRecorder is the mock recorder for MockIS3Tables.

func (*MockIS3TablesMockRecorder) CheckNamespaceExists added in v1.17.0 

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

CheckNamespaceExists indicates an expected call of CheckNamespaceExists.

func (*MockIS3TablesMockRecorder) CheckTableBucketExists added in v1.15.0 

func (mr *MockIS3TablesMockRecorder) CheckTableBucketExists(ctx, tableBucketName any) *gomock.Call

CheckTableBucketExists indicates an expected call of CheckTableBucketExists.

func (*MockIS3TablesMockRecorder) DeleteNamespace added in v1.15.0 

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

DeleteNamespace indicates an expected call of DeleteNamespace.

func (*MockIS3TablesMockRecorder) DeleteTable added in v1.15.0 

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

DeleteTable indicates an expected call of DeleteTable.

func (*MockIS3TablesMockRecorder) DeleteTableBucket added in v1.15.0 

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

DeleteTableBucket indicates an expected call of DeleteTableBucket.

func (*MockIS3TablesMockRecorder) ListNamespacesByPage added in v1.15.0 

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

ListNamespacesByPage indicates an expected call of ListNamespacesByPage.

func (*MockIS3TablesMockRecorder) ListTablesByPage added in v1.15.0 

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

ListTablesByPage indicates an expected call of ListTablesByPage.

type MockIS3Vectors added in v1.17.0 

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

MockIS3Vectors is a mock of IS3Vectors interface.

func NewMockIS3Vectors added in v1.17.0 

func NewMockIS3Vectors(ctrl *gomock.Controller) *MockIS3Vectors

NewMockIS3Vectors creates a new mock instance.

func (*MockIS3Vectors) CheckVectorBucketExists added in v1.17.0 

func (m *MockIS3Vectors) CheckVectorBucketExists(ctx context.Context, vectorBucketName *string) (bool, error)

CheckVectorBucketExists mocks base method.

func (*MockIS3Vectors) DeleteIndex added in v1.17.0 

func (m *MockIS3Vectors) DeleteIndex(ctx context.Context, indexName, vectorBucketName *string) error

DeleteIndex mocks base method.

func (*MockIS3Vectors) DeleteVectorBucket added in v1.17.0 

func (m *MockIS3Vectors) DeleteVectorBucket(ctx context.Context, vectorBucketName *string) error

DeleteVectorBucket mocks base method.

func (*MockIS3Vectors) EXPECT added in v1.17.0 

func (m *MockIS3Vectors) EXPECT() *MockIS3VectorsMockRecorder

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

func (*MockIS3Vectors) ListIndexesByPage added in v1.17.0 

func (m *MockIS3Vectors) ListIndexesByPage(ctx context.Context, vectorBucketName, nextToken, keyPrefix *string) (*ListIndexesByPageOutput, error)

ListIndexesByPage mocks base method.

type MockIS3VectorsMockRecorder added in v1.17.0 

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

MockIS3VectorsMockRecorder is the mock recorder for MockIS3Vectors.

func (*MockIS3VectorsMockRecorder) CheckVectorBucketExists added in v1.17.0 

func (mr *MockIS3VectorsMockRecorder) CheckVectorBucketExists(ctx, vectorBucketName any) *gomock.Call

CheckVectorBucketExists indicates an expected call of CheckVectorBucketExists.

func (*MockIS3VectorsMockRecorder) DeleteIndex added in v1.17.0 

func (mr *MockIS3VectorsMockRecorder) DeleteIndex(ctx, indexName, vectorBucketName any) *gomock.Call

DeleteIndex indicates an expected call of DeleteIndex.

func (*MockIS3VectorsMockRecorder) DeleteVectorBucket added in v1.17.0 

func (mr *MockIS3VectorsMockRecorder) DeleteVectorBucket(ctx, vectorBucketName any) *gomock.Call

DeleteVectorBucket indicates an expected call of DeleteVectorBucket.

func (*MockIS3VectorsMockRecorder) ListIndexesByPage added in v1.17.0 

func (mr *MockIS3VectorsMockRecorder) ListIndexesByPage(ctx, vectorBucketName, nextToken, keyPrefix any) *gomock.Call

ListIndexesByPage indicates an expected call of ListIndexesByPage.

type Retryer added in v0.10.0 

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

func NewRetryer added in v0.10.0 

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

func (*Retryer) GetAttemptToken added in v0.10.0 

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

func (*Retryer) GetInitialToken added in v0.10.0 

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

func (*Retryer) GetRetryToken added in v0.10.0 

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

func (*Retryer) IsErrorRetryable added in v0.10.0 

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

func (*Retryer) MaxAttempts added in v0.10.0 

func (r *Retryer) MaxAttempts() int

func (*Retryer) RetryDelay added in v0.10.0 

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, directoryBucketsFlag bool) *S3

func (*S3) CheckBucketExists 

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

func (*S3) DeleteBucket 

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

func (*S3) DeleteObjects 

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

func (*S3) GetDirectoryBucketsFlag added in v1.11.0 

func (s *S3) GetDirectoryBucketsFlag() bool

func (*S3) ListObjectsOrVersionsByPage added in v1.11.0 

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

type S3Tables added in v1.15.0 

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

func NewS3Tables added in v1.15.0 

func NewS3Tables(client *s3tables.Client) *S3Tables

func (*S3Tables) CheckNamespaceExists added in v1.17.0 

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

func (*S3Tables) CheckTableBucketExists added in v1.15.0 

func (s *S3Tables) CheckTableBucketExists(ctx context.Context, tableBucketName *string) (bool, error)

func (*S3Tables) DeleteNamespace added in v1.15.0 

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

func (*S3Tables) DeleteTable added in v1.15.0 

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

func (*S3Tables) DeleteTableBucket added in v1.15.0 

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

func (*S3Tables) ListNamespacesByPage added in v1.15.0 

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

func (*S3Tables) ListTablesByPage added in v1.15.0 

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

type S3Vectors added in v1.17.0 

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

func NewS3Vectors added in v1.17.0 

func NewS3Vectors(client *s3vectors.Client) *S3Vectors

func (*S3Vectors) CheckVectorBucketExists added in v1.17.0 

func (s *S3Vectors) CheckVectorBucketExists(ctx context.Context, vectorBucketName *string) (bool, error)

func (*S3Vectors) DeleteIndex added in v1.17.0 

func (s *S3Vectors) DeleteIndex(ctx context.Context, indexName *string, vectorBucketName *string) error

func (*S3Vectors) DeleteVectorBucket added in v1.17.0 

func (s *S3Vectors) DeleteVectorBucket(ctx context.Context, vectorBucketName *string) error

func (*S3Vectors) ListIndexesByPage added in v1.17.0 

func (s *S3Vectors) ListIndexesByPage(ctx context.Context, vectorBucketName *string, nextToken *string, keyPrefix *string) (*ListIndexesByPageOutput, 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.