mocks

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Mar 13, 2024 License: MIT Imports: 3 Imported by: 0

Documentation

Overview

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 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) AlterConfig 

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

AlterConfig mocks base method.

func (*MockClusterAdmin) Close 

func (m *MockClusterAdmin) Close() error

Close mocks base method.

func (*MockClusterAdmin) CreateACL 

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

CreateACL 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) 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) 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) DescribeTopics 

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

DescribeTopics 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) 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) ListTopics 

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

ListTopics mocks base method.

type MockClusterAdminMockRecorder 

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

MockClusterAdminMockRecorder is the mock recorder for MockClusterAdmin.

func (*MockClusterAdminMockRecorder) AlterConfig 

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

AlterConfig indicates an expected call of AlterConfig.

func (*MockClusterAdminMockRecorder) Close 

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

Close indicates an expected call of Close.

func (*MockClusterAdminMockRecorder) CreateACL 

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

CreateACL indicates an expected call of CreateACL.

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) 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) 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) DescribeTopics 

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

DescribeTopics indicates an expected call of DescribeTopics.

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) ListTopics 

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

ListTopics indicates an expected call of ListTopics.

type MockFlowMSK 

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

MockFlowMSK is a mock of FlowMSK interface.

func NewMockFlowMSK 

func NewMockFlowMSK(ctrl *gomock.Controller) *MockFlowMSK

NewMockFlowMSK creates a new mock instance.

func (*MockFlowMSK) EXPECT 

func (m *MockFlowMSK) EXPECT() *MockFlowMSKMockRecorder

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

func (*MockFlowMSK) GetBootstrapBrokers 

func (m *MockFlowMSK) GetBootstrapBrokers(clusterName string) (*string, error)

GetBootstrapBrokers mocks base method.

func (*MockFlowMSK) GetClusterArn 

func (m *MockFlowMSK) GetClusterArn(clusterName string) (*string, error)

GetClusterArn mocks base method.

type MockFlowMSKMockRecorder 

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

MockFlowMSKMockRecorder is the mock recorder for MockFlowMSK.

func (*MockFlowMSKMockRecorder) GetBootstrapBrokers 

func (mr *MockFlowMSKMockRecorder) GetBootstrapBrokers(clusterName interface{}) *gomock.Call

GetBootstrapBrokers indicates an expected call of GetBootstrapBrokers.

func (*MockFlowMSKMockRecorder) GetClusterArn 

func (mr *MockFlowMSKMockRecorder) GetClusterArn(clusterName interface{}) *gomock.Call

GetClusterArn indicates an expected call of GetClusterArn.

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.