mocks

package
v0.0.0-...-1a307e6 Latest Latest
Warning

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

 Go to latest Published: Jan 7, 2024 License: MIT-0 Imports: 8 Imported by: 0

Documentation

Overview

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockKafkaClient 

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

MockKafkaClient is a mock of KafkaClient interface.

func NewMockKafkaClient 

func NewMockKafkaClient(ctrl *gomock.Controller) *MockKafkaClient

NewMockKafkaClient creates a new mock instance.

func (*MockKafkaClient) AlterTopicConfigs 

func (m *MockKafkaClient) AlterTopicConfigs(ctx context.Context, configs []kadm.AlterConfig, topics ...string) (kadm.AlterConfigsResponses, error)

AlterTopicConfigs mocks base method.

func (*MockKafkaClient) CreateACLs 

func (m *MockKafkaClient) CreateACLs(ctx context.Context, b *kadm.ACLBuilder) (kadm.CreateACLsResults, error)

CreateACLs mocks base method.

func (*MockKafkaClient) CreateTopic 

func (m *MockKafkaClient) CreateTopic(ctx context.Context, partitions int32, replicationFactor int16, configs map[string]*string, topic string) (kadm.CreateTopicResponse, error)

CreateTopic mocks base method.

func (*MockKafkaClient) DeleteACLs 

func (m *MockKafkaClient) DeleteACLs(ctx context.Context, b *kadm.ACLBuilder) (kadm.DeleteACLsResults, error)

DeleteACLs mocks base method.

func (*MockKafkaClient) DeleteTopics 

func (m *MockKafkaClient) DeleteTopics(ctx context.Context, topics ...string) (kadm.DeleteTopicResponses, error)

DeleteTopics mocks base method.

func (*MockKafkaClient) DescribeACLs 

func (m *MockKafkaClient) DescribeACLs(ctx context.Context, b *kadm.ACLBuilder) (kadm.DescribeACLsResults, error)

DescribeACLs mocks base method.

func (*MockKafkaClient) DescribeTopicConfigs 

func (m *MockKafkaClient) DescribeTopicConfigs(ctx context.Context, topics ...string) (kadm.ResourceConfigs, error)

DescribeTopicConfigs mocks base method.

func (*MockKafkaClient) EXPECT 

func (m *MockKafkaClient) EXPECT() *MockKafkaClientMockRecorder

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

func (*MockKafkaClient) ListTopics 

func (m *MockKafkaClient) ListTopics(ctx context.Context, topics ...string) (kadm.TopicDetails, error)

ListTopics mocks base method.

type MockKafkaClientMockRecorder 

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

MockKafkaClientMockRecorder is the mock recorder for MockKafkaClient.

func (*MockKafkaClientMockRecorder) AlterTopicConfigs 

func (mr *MockKafkaClientMockRecorder) AlterTopicConfigs(ctx, configs interface{}, topics ...interface{}) *gomock.Call

AlterTopicConfigs indicates an expected call of AlterTopicConfigs.

func (*MockKafkaClientMockRecorder) CreateACLs 

func (mr *MockKafkaClientMockRecorder) CreateACLs(ctx, b interface{}) *gomock.Call

CreateACLs indicates an expected call of CreateACLs.

func (*MockKafkaClientMockRecorder) CreateTopic 

func (mr *MockKafkaClientMockRecorder) CreateTopic(ctx, partitions, replicationFactor, configs, topic interface{}) *gomock.Call

CreateTopic indicates an expected call of CreateTopic.

func (*MockKafkaClientMockRecorder) DeleteACLs 

func (mr *MockKafkaClientMockRecorder) DeleteACLs(ctx, b interface{}) *gomock.Call

DeleteACLs indicates an expected call of DeleteACLs.

func (*MockKafkaClientMockRecorder) DeleteTopics 

func (mr *MockKafkaClientMockRecorder) DeleteTopics(ctx interface{}, topics ...interface{}) *gomock.Call

DeleteTopics indicates an expected call of DeleteTopics.

func (*MockKafkaClientMockRecorder) DescribeACLs 

func (mr *MockKafkaClientMockRecorder) DescribeACLs(ctx, b interface{}) *gomock.Call

DescribeACLs indicates an expected call of DescribeACLs.

func (*MockKafkaClientMockRecorder) DescribeTopicConfigs 

func (mr *MockKafkaClientMockRecorder) DescribeTopicConfigs(ctx interface{}, topics ...interface{}) *gomock.Call

DescribeTopicConfigs indicates an expected call of DescribeTopicConfigs.

func (*MockKafkaClientMockRecorder) ListTopics 

func (mr *MockKafkaClientMockRecorder) ListTopics(ctx interface{}, topics ...interface{}) *gomock.Call

ListTopics indicates an expected call of ListTopics.

type MockKmsClient 

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

MockKmsClient is a mock of KmsClient interface.

func NewMockKmsClient 

func NewMockKmsClient(ctrl *gomock.Controller) *MockKmsClient

NewMockKmsClient creates a new mock instance.

func (*MockKmsClient) CreateGrant 

func (m *MockKmsClient) CreateGrant(ctx context.Context, params *kms.CreateGrantInput, optFns ...func(*kms.Options)) (*kms.CreateGrantOutput, error)

CreateGrant mocks base method.

func (*MockKmsClient) EXPECT 

func (m *MockKmsClient) EXPECT() *MockKmsClientMockRecorder

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

func (*MockKmsClient) RevokeGrant 

func (m *MockKmsClient) RevokeGrant(ctx context.Context, params *kms.RevokeGrantInput, optFns ...func(*kms.Options)) (*kms.RevokeGrantOutput, error)

RevokeGrant mocks base method.

type MockKmsClientMockRecorder 

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

MockKmsClientMockRecorder is the mock recorder for MockKmsClient.

func (*MockKmsClientMockRecorder) CreateGrant 

func (mr *MockKmsClientMockRecorder) CreateGrant(ctx, params interface{}, optFns ...interface{}) *gomock.Call

CreateGrant indicates an expected call of CreateGrant.

func (*MockKmsClientMockRecorder) RevokeGrant 

func (mr *MockKmsClientMockRecorder) RevokeGrant(ctx, params interface{}, optFns ...interface{}) *gomock.Call

RevokeGrant indicates an expected call of RevokeGrant.

type MockKmsKeyResolverService 

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

MockKmsKeyResolverService is a mock of KmsKeyResolverService interface.

func NewMockKmsKeyResolverService 

func NewMockKmsKeyResolverService(ctrl *gomock.Controller) *MockKmsKeyResolverService

NewMockKmsKeyResolverService creates a new mock instance.

func (*MockKmsKeyResolverService) EXPECT 

func (m *MockKmsKeyResolverService) EXPECT() *MockKmsKeyResolverServiceMockRecorder

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

func (*MockKmsKeyResolverService) Resolve 

func (m *MockKmsKeyResolverService) Resolve(ctx context.Context, info *types.TopicInfo) (string, error)

Resolve mocks base method.

type MockKmsKeyResolverServiceMockRecorder 

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

MockKmsKeyResolverServiceMockRecorder is the mock recorder for MockKmsKeyResolverService.

func (*MockKmsKeyResolverServiceMockRecorder) Resolve 

func (mr *MockKmsKeyResolverServiceMockRecorder) Resolve(ctx, info interface{}) *gomock.Call

Resolve indicates an expected call of Resolve.

type MockMskClient 

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

MockMskClient is a mock of MskClient interface.

func NewMockMskClient 

func NewMockMskClient(ctrl *gomock.Controller) *MockMskClient

NewMockMskClient creates a new mock instance.

func (*MockMskClient) BatchAssociateScramSecret 

func (m *MockMskClient) BatchAssociateScramSecret(ctx context.Context, params *kafka.BatchAssociateScramSecretInput, optFns ...func(*kafka.Options)) (*kafka.BatchAssociateScramSecretOutput, error)

BatchAssociateScramSecret mocks base method.

func (*MockMskClient) BatchDisassociateScramSecret 

func (m *MockMskClient) BatchDisassociateScramSecret(ctx context.Context, params *kafka.BatchDisassociateScramSecretInput, optFns ...func(*kafka.Options)) (*kafka.BatchDisassociateScramSecretOutput, error)

BatchDisassociateScramSecret mocks base method.

func (*MockMskClient) DescribeCluster 

func (m *MockMskClient) DescribeCluster(ctx context.Context, params *kafka.DescribeClusterInput, optFns ...func(*kafka.Options)) (*kafka.DescribeClusterOutput, error)

DescribeCluster mocks base method.

func (*MockMskClient) EXPECT 

func (m *MockMskClient) EXPECT() *MockMskClientMockRecorder

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

func (*MockMskClient) GetBootstrapBrokers 

func (m *MockMskClient) GetBootstrapBrokers(ctx context.Context, params *kafka.GetBootstrapBrokersInput, optFns ...func(*kafka.Options)) (*kafka.GetBootstrapBrokersOutput, error)

GetBootstrapBrokers mocks base method.

type MockMskClientMockRecorder 

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

MockMskClientMockRecorder is the mock recorder for MockMskClient.

func (*MockMskClientMockRecorder) BatchAssociateScramSecret 

func (mr *MockMskClientMockRecorder) BatchAssociateScramSecret(ctx, params interface{}, optFns ...interface{}) *gomock.Call

BatchAssociateScramSecret indicates an expected call of BatchAssociateScramSecret.

func (*MockMskClientMockRecorder) BatchDisassociateScramSecret 

func (mr *MockMskClientMockRecorder) BatchDisassociateScramSecret(ctx, params interface{}, optFns ...interface{}) *gomock.Call

BatchDisassociateScramSecret indicates an expected call of BatchDisassociateScramSecret.

func (*MockMskClientMockRecorder) DescribeCluster 

func (mr *MockMskClientMockRecorder) DescribeCluster(ctx, params interface{}, optFns ...interface{}) *gomock.Call

DescribeCluster indicates an expected call of DescribeCluster.

func (*MockMskClientMockRecorder) GetBootstrapBrokers 

func (mr *MockMskClientMockRecorder) GetBootstrapBrokers(ctx, params interface{}, optFns ...interface{}) *gomock.Call

GetBootstrapBrokers indicates an expected call of GetBootstrapBrokers.

type MockSecretsManagerClient 

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

MockSecretsManagerClient is a mock of SecretsManagerClient interface.

func NewMockSecretsManagerClient 

func NewMockSecretsManagerClient(ctrl *gomock.Controller) *MockSecretsManagerClient

NewMockSecretsManagerClient creates a new mock instance.

func (*MockSecretsManagerClient) CreateSecret 

func (m *MockSecretsManagerClient) CreateSecret(ctx context.Context, params *secretsmanager.CreateSecretInput, optFns ...func(*secretsmanager.Options)) (*secretsmanager.CreateSecretOutput, error)

CreateSecret mocks base method.

func (*MockSecretsManagerClient) DeleteSecret 

func (m *MockSecretsManagerClient) DeleteSecret(ctx context.Context, params *secretsmanager.DeleteSecretInput, optFns ...func(*secretsmanager.Options)) (*secretsmanager.DeleteSecretOutput, error)

DeleteSecret mocks base method.

func (*MockSecretsManagerClient) DescribeSecret 

func (m *MockSecretsManagerClient) DescribeSecret(ctx context.Context, params *secretsmanager.DescribeSecretInput, optFns ...func(*secretsmanager.Options)) (*secretsmanager.DescribeSecretOutput, error)

DescribeSecret mocks base method.

func (*MockSecretsManagerClient) EXPECT 

func (m *MockSecretsManagerClient) EXPECT() *MockSecretsManagerClientMockRecorder

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

func (*MockSecretsManagerClient) ListSecrets 

func (m *MockSecretsManagerClient) ListSecrets(ctx context.Context, params *secretsmanager.ListSecretsInput, optFns ...func(*secretsmanager.Options)) (*secretsmanager.ListSecretsOutput, error)

ListSecrets mocks base method.

func (*MockSecretsManagerClient) PutResourcePolicy 

func (m *MockSecretsManagerClient) PutResourcePolicy(ctx context.Context, params *secretsmanager.PutResourcePolicyInput, optFns ...func(*secretsmanager.Options)) (*secretsmanager.PutResourcePolicyOutput, error)

PutResourcePolicy mocks base method.

type MockSecretsManagerClientMockRecorder 

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

MockSecretsManagerClientMockRecorder is the mock recorder for MockSecretsManagerClient.

func (*MockSecretsManagerClientMockRecorder) CreateSecret 

func (mr *MockSecretsManagerClientMockRecorder) CreateSecret(ctx, params interface{}, optFns ...interface{}) *gomock.Call

CreateSecret indicates an expected call of CreateSecret.

func (*MockSecretsManagerClientMockRecorder) DeleteSecret 

func (mr *MockSecretsManagerClientMockRecorder) DeleteSecret(ctx, params interface{}, optFns ...interface{}) *gomock.Call

DeleteSecret indicates an expected call of DeleteSecret.

func (*MockSecretsManagerClientMockRecorder) DescribeSecret 

func (mr *MockSecretsManagerClientMockRecorder) DescribeSecret(ctx, params interface{}, optFns ...interface{}) *gomock.Call

DescribeSecret indicates an expected call of DescribeSecret.

func (*MockSecretsManagerClientMockRecorder) ListSecrets 

func (mr *MockSecretsManagerClientMockRecorder) ListSecrets(ctx, params interface{}, optFns ...interface{}) *gomock.Call

ListSecrets indicates an expected call of ListSecrets.

func (*MockSecretsManagerClientMockRecorder) PutResourcePolicy 

func (mr *MockSecretsManagerClientMockRecorder) PutResourcePolicy(ctx, params interface{}, optFns ...interface{}) *gomock.Call

PutResourcePolicy indicates an expected call of PutResourcePolicy.

type MockUserManagerService 

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

MockUserManagerService is a mock of UserManagerService interface.

func NewMockUserManagerService 

func NewMockUserManagerService(ctrl *gomock.Controller) *MockUserManagerService

NewMockUserManagerService creates a new mock instance.

func (*MockUserManagerService) CreateACLs 

func (m *MockUserManagerService) CreateACLs(ctx context.Context, topic, username, shortStackID string, permissions []types.Permission) error

CreateACLs mocks base method.

func (*MockUserManagerService) CreateUser 

func (m *MockUserManagerService) CreateUser(ctx context.Context, shortStackID, topic, kmsKeyID, clusterArn string, u *types.User) error

CreateUser mocks base method.

func (*MockUserManagerService) DeleteACLs 

func (m *MockUserManagerService) DeleteACLs(ctx context.Context, topic, username, shortStackID string, permissions []types.Permission) error

DeleteACLs mocks base method.

func (*MockUserManagerService) DeleteUser 

func (m *MockUserManagerService) DeleteUser(ctx context.Context, u *types.User, kmsKeyID, topic, shortStackID, clusterArn string) error

DeleteUser mocks base method.

func (*MockUserManagerService) EXPECT 

func (m *MockUserManagerService) EXPECT() *MockUserManagerServiceMockRecorder

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

type MockUserManagerServiceMockRecorder 

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

MockUserManagerServiceMockRecorder is the mock recorder for MockUserManagerService.

func (*MockUserManagerServiceMockRecorder) CreateACLs 

func (mr *MockUserManagerServiceMockRecorder) CreateACLs(ctx, topic, username, shortStackID, permissions interface{}) *gomock.Call

CreateACLs indicates an expected call of CreateACLs.

func (*MockUserManagerServiceMockRecorder) CreateUser 

func (mr *MockUserManagerServiceMockRecorder) CreateUser(ctx, shortStackID, topic, kmsKeyID, clusterArn, u interface{}) *gomock.Call

CreateUser indicates an expected call of CreateUser.

func (*MockUserManagerServiceMockRecorder) DeleteACLs 

func (mr *MockUserManagerServiceMockRecorder) DeleteACLs(ctx, topic, username, shortStackID, permissions interface{}) *gomock.Call

DeleteACLs indicates an expected call of DeleteACLs.

func (*MockUserManagerServiceMockRecorder) DeleteUser 

func (mr *MockUserManagerServiceMockRecorder) DeleteUser(ctx, u, kmsKeyID, topic, shortStackID, clusterArn interface{}) *gomock.Call

DeleteUser indicates an expected call of DeleteUser.

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.