kafkaaclsmocks

package
v0.1.15 Latest Latest
Warning

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

 Go to latest Published: Feb 5, 2023 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Overview

Package kafkaaclsmocks is a generated GoMock package.

Package kafkaaclsmocks is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockClusterAdmin 

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

MockClusterAdmin is a mock of ClusterAdmin interface.

func NewMockClusterAdmin 

func NewMockClusterAdmin(ctrl *gomock.Controller) *MockClusterAdmin

NewMockClusterAdmin creates a new mock instance.

func (*MockClusterAdmin) AlterClientQuotas 

func (m *MockClusterAdmin) AlterClientQuotas(arg0 []sarama.QuotaEntityComponent, arg1 sarama.ClientQuotasOp, arg2 bool) error

AlterClientQuotas mocks base method.

func (*MockClusterAdmin) AlterConfig 

func (m *MockClusterAdmin) AlterConfig(arg0 sarama.ConfigResourceType, arg1 string, arg2 map[string]*string, arg3 bool) error

AlterConfig mocks base method.

func (*MockClusterAdmin) AlterPartitionReassignments 

func (m *MockClusterAdmin) AlterPartitionReassignments(arg0 string, arg1 [][]int32) error

AlterPartitionReassignments mocks base method.

func (*MockClusterAdmin) Close 

func (m *MockClusterAdmin) Close() error

Close mocks base method.

func (*MockClusterAdmin) Controller 

func (m *MockClusterAdmin) Controller() (*sarama.Broker, error)

Controller mocks base method.

func (*MockClusterAdmin) CreateACL 

func (m *MockClusterAdmin) CreateACL(arg0 sarama.Resource, arg1 sarama.Acl) error

CreateACL mocks base method.

func (*MockClusterAdmin) CreateACLs 

func (m *MockClusterAdmin) CreateACLs(arg0 []*sarama.ResourceAcls) error

CreateACLs mocks base method.

func (*MockClusterAdmin) CreatePartitions 

func (m *MockClusterAdmin) CreatePartitions(arg0 string, arg1 int32, arg2 [][]int32, arg3 bool) error

CreatePartitions mocks base method.

func (*MockClusterAdmin) CreateTopic 

func (m *MockClusterAdmin) CreateTopic(arg0 string, arg1 *sarama.TopicDetail, arg2 bool) error

CreateTopic mocks base method.

func (*MockClusterAdmin) DeleteACL 

func (m *MockClusterAdmin) DeleteACL(arg0 sarama.AclFilter, arg1 bool) ([]sarama.MatchingAcl, error)

DeleteACL mocks base method.

func (*MockClusterAdmin) DeleteConsumerGroup 

func (m *MockClusterAdmin) DeleteConsumerGroup(arg0 string) error

DeleteConsumerGroup mocks base method.

func (*MockClusterAdmin) DeleteConsumerGroupOffset 

func (m *MockClusterAdmin) DeleteConsumerGroupOffset(arg0, arg1 string, arg2 int32) error

DeleteConsumerGroupOffset mocks base method.

func (*MockClusterAdmin) DeleteRecords 

func (m *MockClusterAdmin) DeleteRecords(arg0 string, arg1 map[int32]int64) error

DeleteRecords mocks base method.

func (*MockClusterAdmin) DeleteTopic 

func (m *MockClusterAdmin) DeleteTopic(arg0 string) error

DeleteTopic mocks base method.

func (*MockClusterAdmin) DeleteUserScramCredentials 

func (m *MockClusterAdmin) DeleteUserScramCredentials(arg0 []sarama.AlterUserScramCredentialsDelete) ([]*sarama.AlterUserScramCredentialsResult, error)

DeleteUserScramCredentials mocks base method.

func (*MockClusterAdmin) DescribeClientQuotas 

func (m *MockClusterAdmin) DescribeClientQuotas(arg0 []sarama.QuotaFilterComponent, arg1 bool) ([]sarama.DescribeClientQuotasEntry, error)

DescribeClientQuotas mocks base method.

func (*MockClusterAdmin) DescribeCluster 

func (m *MockClusterAdmin) DescribeCluster() ([]*sarama.Broker, int32, error)

DescribeCluster mocks base method.

func (*MockClusterAdmin) DescribeConfig 

func (m *MockClusterAdmin) DescribeConfig(arg0 sarama.ConfigResource) ([]sarama.ConfigEntry, error)

DescribeConfig mocks base method.

func (*MockClusterAdmin) DescribeConsumerGroups 

func (m *MockClusterAdmin) DescribeConsumerGroups(arg0 []string) ([]*sarama.GroupDescription, error)

DescribeConsumerGroups mocks base method.

func (*MockClusterAdmin) DescribeLogDirs 

func (m *MockClusterAdmin) DescribeLogDirs(arg0 []int32) (map[int32][]sarama.DescribeLogDirsResponseDirMetadata, error)

DescribeLogDirs mocks base method.

func (*MockClusterAdmin) DescribeTopics 

func (m *MockClusterAdmin) DescribeTopics(arg0 []string) ([]*sarama.TopicMetadata, error)

DescribeTopics mocks base method.

func (*MockClusterAdmin) DescribeUserScramCredentials 

func (m *MockClusterAdmin) DescribeUserScramCredentials(arg0 []string) ([]*sarama.DescribeUserScramCredentialsResult, error)

DescribeUserScramCredentials mocks base method.

func (*MockClusterAdmin) EXPECT 

func (m *MockClusterAdmin) EXPECT() *MockClusterAdminMockRecorder

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

func (*MockClusterAdmin) IncrementalAlterConfig 

func (m *MockClusterAdmin) IncrementalAlterConfig(arg0 sarama.ConfigResourceType, arg1 string, arg2 map[string]sarama.IncrementalAlterConfigsEntry, arg3 bool) error

IncrementalAlterConfig mocks base method.

func (*MockClusterAdmin) ListAcls 

func (m *MockClusterAdmin) ListAcls(arg0 sarama.AclFilter) ([]sarama.ResourceAcls, error)

ListAcls mocks base method.

func (*MockClusterAdmin) ListConsumerGroupOffsets 

func (m *MockClusterAdmin) ListConsumerGroupOffsets(arg0 string, arg1 map[string][]int32) (*sarama.OffsetFetchResponse, error)

ListConsumerGroupOffsets mocks base method.

func (*MockClusterAdmin) ListConsumerGroups 

func (m *MockClusterAdmin) ListConsumerGroups() (map[string]string, error)

ListConsumerGroups mocks base method.

func (*MockClusterAdmin) ListPartitionReassignments 

func (m *MockClusterAdmin) ListPartitionReassignments(arg0 string, arg1 []int32) (map[string]map[int32]*sarama.PartitionReplicaReassignmentsStatus, error)

ListPartitionReassignments mocks base method.

func (*MockClusterAdmin) ListTopics 

func (m *MockClusterAdmin) ListTopics() (map[string]sarama.TopicDetail, error)

ListTopics mocks base method.

func (*MockClusterAdmin) RemoveMemberFromConsumerGroup 

func (m *MockClusterAdmin) RemoveMemberFromConsumerGroup(arg0 string, arg1 []string) (*sarama.LeaveGroupResponse, error)

RemoveMemberFromConsumerGroup mocks base method.

func (*MockClusterAdmin) UpsertUserScramCredentials 

func (m *MockClusterAdmin) UpsertUserScramCredentials(arg0 []sarama.AlterUserScramCredentialsUpsert) ([]*sarama.AlterUserScramCredentialsResult, error)

UpsertUserScramCredentials mocks base method.

type MockClusterAdminMockRecorder 

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

MockClusterAdminMockRecorder is the mock recorder for MockClusterAdmin.

func (*MockClusterAdminMockRecorder) AlterClientQuotas 

func (mr *MockClusterAdminMockRecorder) AlterClientQuotas(arg0, arg1, arg2 interface{}) *gomock.Call

AlterClientQuotas indicates an expected call of AlterClientQuotas.

func (*MockClusterAdminMockRecorder) AlterConfig 

func (mr *MockClusterAdminMockRecorder) AlterConfig(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

AlterConfig indicates an expected call of AlterConfig.

func (*MockClusterAdminMockRecorder) AlterPartitionReassignments 

func (mr *MockClusterAdminMockRecorder) AlterPartitionReassignments(arg0, arg1 interface{}) *gomock.Call

AlterPartitionReassignments indicates an expected call of AlterPartitionReassignments.

func (*MockClusterAdminMockRecorder) Close 

func (mr *MockClusterAdminMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockClusterAdminMockRecorder) Controller 

func (mr *MockClusterAdminMockRecorder) Controller() *gomock.Call

Controller indicates an expected call of Controller.

func (*MockClusterAdminMockRecorder) CreateACL 

func (mr *MockClusterAdminMockRecorder) CreateACL(arg0, arg1 interface{}) *gomock.Call

CreateACL indicates an expected call of CreateACL.

func (*MockClusterAdminMockRecorder) CreateACLs 

func (mr *MockClusterAdminMockRecorder) CreateACLs(arg0 interface{}) *gomock.Call

CreateACLs indicates an expected call of CreateACLs.

func (*MockClusterAdminMockRecorder) CreatePartitions 

func (mr *MockClusterAdminMockRecorder) CreatePartitions(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

CreatePartitions indicates an expected call of CreatePartitions.

func (*MockClusterAdminMockRecorder) CreateTopic 

func (mr *MockClusterAdminMockRecorder) CreateTopic(arg0, arg1, arg2 interface{}) *gomock.Call

CreateTopic indicates an expected call of CreateTopic.

func (*MockClusterAdminMockRecorder) DeleteACL 

func (mr *MockClusterAdminMockRecorder) DeleteACL(arg0, arg1 interface{}) *gomock.Call

DeleteACL indicates an expected call of DeleteACL.

func (*MockClusterAdminMockRecorder) DeleteConsumerGroup 

func (mr *MockClusterAdminMockRecorder) DeleteConsumerGroup(arg0 interface{}) *gomock.Call

DeleteConsumerGroup indicates an expected call of DeleteConsumerGroup.

func (*MockClusterAdminMockRecorder) DeleteConsumerGroupOffset 

func (mr *MockClusterAdminMockRecorder) DeleteConsumerGroupOffset(arg0, arg1, arg2 interface{}) *gomock.Call

DeleteConsumerGroupOffset indicates an expected call of DeleteConsumerGroupOffset.

func (*MockClusterAdminMockRecorder) DeleteRecords 

func (mr *MockClusterAdminMockRecorder) DeleteRecords(arg0, arg1 interface{}) *gomock.Call

DeleteRecords indicates an expected call of DeleteRecords.

func (*MockClusterAdminMockRecorder) DeleteTopic 

func (mr *MockClusterAdminMockRecorder) DeleteTopic(arg0 interface{}) *gomock.Call

DeleteTopic indicates an expected call of DeleteTopic.

func (*MockClusterAdminMockRecorder) DeleteUserScramCredentials 

func (mr *MockClusterAdminMockRecorder) DeleteUserScramCredentials(arg0 interface{}) *gomock.Call

DeleteUserScramCredentials indicates an expected call of DeleteUserScramCredentials.

func (*MockClusterAdminMockRecorder) DescribeClientQuotas 

func (mr *MockClusterAdminMockRecorder) DescribeClientQuotas(arg0, arg1 interface{}) *gomock.Call

DescribeClientQuotas indicates an expected call of DescribeClientQuotas.

func (*MockClusterAdminMockRecorder) DescribeCluster 

func (mr *MockClusterAdminMockRecorder) DescribeCluster() *gomock.Call

DescribeCluster indicates an expected call of DescribeCluster.

func (*MockClusterAdminMockRecorder) DescribeConfig 

func (mr *MockClusterAdminMockRecorder) DescribeConfig(arg0 interface{}) *gomock.Call

DescribeConfig indicates an expected call of DescribeConfig.

func (*MockClusterAdminMockRecorder) DescribeConsumerGroups 

func (mr *MockClusterAdminMockRecorder) DescribeConsumerGroups(arg0 interface{}) *gomock.Call

DescribeConsumerGroups indicates an expected call of DescribeConsumerGroups.

func (*MockClusterAdminMockRecorder) DescribeLogDirs 

func (mr *MockClusterAdminMockRecorder) DescribeLogDirs(arg0 interface{}) *gomock.Call

DescribeLogDirs indicates an expected call of DescribeLogDirs.

func (*MockClusterAdminMockRecorder) DescribeTopics 

func (mr *MockClusterAdminMockRecorder) DescribeTopics(arg0 interface{}) *gomock.Call

DescribeTopics indicates an expected call of DescribeTopics.

func (*MockClusterAdminMockRecorder) DescribeUserScramCredentials 

func (mr *MockClusterAdminMockRecorder) DescribeUserScramCredentials(arg0 interface{}) *gomock.Call

DescribeUserScramCredentials indicates an expected call of DescribeUserScramCredentials.

func (*MockClusterAdminMockRecorder) IncrementalAlterConfig 

func (mr *MockClusterAdminMockRecorder) IncrementalAlterConfig(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

IncrementalAlterConfig indicates an expected call of IncrementalAlterConfig.

func (*MockClusterAdminMockRecorder) ListAcls 

func (mr *MockClusterAdminMockRecorder) ListAcls(arg0 interface{}) *gomock.Call

ListAcls indicates an expected call of ListAcls.

func (*MockClusterAdminMockRecorder) ListConsumerGroupOffsets 

func (mr *MockClusterAdminMockRecorder) ListConsumerGroupOffsets(arg0, arg1 interface{}) *gomock.Call

ListConsumerGroupOffsets indicates an expected call of ListConsumerGroupOffsets.

func (*MockClusterAdminMockRecorder) ListConsumerGroups 

func (mr *MockClusterAdminMockRecorder) ListConsumerGroups() *gomock.Call

ListConsumerGroups indicates an expected call of ListConsumerGroups.

func (*MockClusterAdminMockRecorder) ListPartitionReassignments 

func (mr *MockClusterAdminMockRecorder) ListPartitionReassignments(arg0, arg1 interface{}) *gomock.Call

ListPartitionReassignments indicates an expected call of ListPartitionReassignments.

func (*MockClusterAdminMockRecorder) ListTopics 

func (mr *MockClusterAdminMockRecorder) ListTopics() *gomock.Call

ListTopics indicates an expected call of ListTopics.

func (*MockClusterAdminMockRecorder) RemoveMemberFromConsumerGroup 

func (mr *MockClusterAdminMockRecorder) RemoveMemberFromConsumerGroup(arg0, arg1 interface{}) *gomock.Call

RemoveMemberFromConsumerGroup indicates an expected call of RemoveMemberFromConsumerGroup.

func (*MockClusterAdminMockRecorder) UpsertUserScramCredentials 

func (mr *MockClusterAdminMockRecorder) UpsertUserScramCredentials(arg0 interface{}) *gomock.Call

UpsertUserScramCredentials indicates an expected call of UpsertUserScramCredentials.

type MockKafkaIntentsAdmin 

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

MockKafkaIntentsAdmin is a mock of KafkaIntentsAdmin interface.

func NewMockKafkaIntentsAdmin 

func NewMockKafkaIntentsAdmin(ctrl *gomock.Controller) *MockKafkaIntentsAdmin

NewMockKafkaIntentsAdmin creates a new mock instance.

func (*MockKafkaIntentsAdmin) ApplyClientIntents 

func (m *MockKafkaIntentsAdmin) ApplyClientIntents(clientName, clientNamespace string, intents []v1alpha2.Intent) error

ApplyClientIntents mocks base method.

func (*MockKafkaIntentsAdmin) ApplyServerTopicsConf 

func (m *MockKafkaIntentsAdmin) ApplyServerTopicsConf(topicsConf []v1alpha2.TopicConfig) error

ApplyServerTopicsConf mocks base method.

func (*MockKafkaIntentsAdmin) Close 

func (m *MockKafkaIntentsAdmin) Close()

Close mocks base method.

func (*MockKafkaIntentsAdmin) EXPECT 

func (m *MockKafkaIntentsAdmin) EXPECT() *MockKafkaIntentsAdminMockRecorder

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

func (*MockKafkaIntentsAdmin) RemoveAllIntents 

func (m *MockKafkaIntentsAdmin) RemoveAllIntents() error

RemoveAllIntents mocks base method.

func (*MockKafkaIntentsAdmin) RemoveClientIntents 

func (m *MockKafkaIntentsAdmin) RemoveClientIntents(clientName, clientNamespace string) error

RemoveClientIntents mocks base method.

type MockKafkaIntentsAdminMockRecorder 

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

MockKafkaIntentsAdminMockRecorder is the mock recorder for MockKafkaIntentsAdmin.

func (*MockKafkaIntentsAdminMockRecorder) ApplyClientIntents 

func (mr *MockKafkaIntentsAdminMockRecorder) ApplyClientIntents(clientName, clientNamespace, intents interface{}) *gomock.Call

ApplyClientIntents indicates an expected call of ApplyClientIntents.

func (*MockKafkaIntentsAdminMockRecorder) ApplyServerTopicsConf 

func (mr *MockKafkaIntentsAdminMockRecorder) ApplyServerTopicsConf(topicsConf interface{}) *gomock.Call

ApplyServerTopicsConf indicates an expected call of ApplyServerTopicsConf.

func (*MockKafkaIntentsAdminMockRecorder) Close 

func (mr *MockKafkaIntentsAdminMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockKafkaIntentsAdminMockRecorder) RemoveAllIntents 

func (mr *MockKafkaIntentsAdminMockRecorder) RemoveAllIntents() *gomock.Call

RemoveAllIntents indicates an expected call of RemoveAllIntents.

func (*MockKafkaIntentsAdminMockRecorder) RemoveClientIntents 

func (mr *MockKafkaIntentsAdminMockRecorder) RemoveClientIntents(clientName, clientNamespace interface{}) *gomock.Call

RemoveClientIntents indicates an expected call of RemoveClientIntents.

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.