mocks

package
v0.1.75 Latest Latest
Warning

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

 Go to latest Published: Oct 3, 2019 License: MIT Imports: 4 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 MockClusterAdmin added in v0.1.74 

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

MockClusterAdmin is a mock of ClusterAdmin interface

func NewMockClusterAdmin added in v0.1.74 

func NewMockClusterAdmin(ctrl *gomock.Controller) *MockClusterAdmin

NewMockClusterAdmin creates a new mock instance

func (*MockClusterAdmin) AlterConfig added in v0.1.74 

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

AlterConfig mocks base method

func (*MockClusterAdmin) Close added in v0.1.74 

func (m *MockClusterAdmin) Close() error

Close mocks base method

func (*MockClusterAdmin) CreateACL added in v0.1.74 

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

CreateACL mocks base method

func (*MockClusterAdmin) CreatePartitions added in v0.1.74 

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

CreatePartitions mocks base method

func (*MockClusterAdmin) CreateTopic added in v0.1.74 

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

CreateTopic mocks base method

func (*MockClusterAdmin) DeleteACL added in v0.1.74 

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

DeleteACL mocks base method

func (*MockClusterAdmin) DeleteConsumerGroup added in v0.1.74 

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

DeleteConsumerGroup mocks base method

func (*MockClusterAdmin) DeleteRecords added in v0.1.74 

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

DeleteRecords mocks base method

func (*MockClusterAdmin) DeleteTopic added in v0.1.74 

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

DeleteTopic mocks base method

func (*MockClusterAdmin) DescribeCluster added in v0.1.74 

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

DescribeCluster mocks base method

func (*MockClusterAdmin) DescribeConfig added in v0.1.74 

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

DescribeConfig mocks base method

func (*MockClusterAdmin) DescribeConsumerGroups added in v0.1.74 

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

DescribeConsumerGroups mocks base method

func (*MockClusterAdmin) DescribeTopics added in v0.1.74 

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

DescribeTopics mocks base method

func (*MockClusterAdmin) EXPECT added in v0.1.74 

func (m *MockClusterAdmin) EXPECT() *MockClusterAdminMockRecorder

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

func (*MockClusterAdmin) ListAcls added in v0.1.74 

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

ListAcls mocks base method

func (*MockClusterAdmin) ListConsumerGroupOffsets added in v0.1.74 

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

ListConsumerGroupOffsets mocks base method

func (*MockClusterAdmin) ListConsumerGroups added in v0.1.74 

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

ListConsumerGroups mocks base method

func (*MockClusterAdmin) ListTopics added in v0.1.74 

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

ListTopics mocks base method

type MockClusterAdminMockRecorder added in v0.1.74 

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

MockClusterAdminMockRecorder is the mock recorder for MockClusterAdmin

func (*MockClusterAdminMockRecorder) AlterConfig added in v0.1.74 

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

AlterConfig indicates an expected call of AlterConfig

func (*MockClusterAdminMockRecorder) Close added in v0.1.74 

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

Close indicates an expected call of Close

func (*MockClusterAdminMockRecorder) CreateACL added in v0.1.74 

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

CreateACL indicates an expected call of CreateACL

func (*MockClusterAdminMockRecorder) CreatePartitions added in v0.1.74 

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

CreatePartitions indicates an expected call of CreatePartitions

func (*MockClusterAdminMockRecorder) CreateTopic added in v0.1.74 

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

CreateTopic indicates an expected call of CreateTopic

func (*MockClusterAdminMockRecorder) DeleteACL added in v0.1.74 

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

DeleteACL indicates an expected call of DeleteACL

func (*MockClusterAdminMockRecorder) DeleteConsumerGroup added in v0.1.74 

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

DeleteConsumerGroup indicates an expected call of DeleteConsumerGroup

func (*MockClusterAdminMockRecorder) DeleteRecords added in v0.1.74 

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

DeleteRecords indicates an expected call of DeleteRecords

func (*MockClusterAdminMockRecorder) DeleteTopic added in v0.1.74 

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

DeleteTopic indicates an expected call of DeleteTopic

func (*MockClusterAdminMockRecorder) DescribeCluster added in v0.1.74 

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

DescribeCluster indicates an expected call of DescribeCluster

func (*MockClusterAdminMockRecorder) DescribeConfig added in v0.1.74 

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

DescribeConfig indicates an expected call of DescribeConfig

func (*MockClusterAdminMockRecorder) DescribeConsumerGroups added in v0.1.74 

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

DescribeConsumerGroups indicates an expected call of DescribeConsumerGroups

func (*MockClusterAdminMockRecorder) DescribeTopics added in v0.1.74 

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

DescribeTopics indicates an expected call of DescribeTopics

func (*MockClusterAdminMockRecorder) ListAcls added in v0.1.74 

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

ListAcls indicates an expected call of ListAcls

func (*MockClusterAdminMockRecorder) ListConsumerGroupOffsets added in v0.1.74 

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

ListConsumerGroupOffsets indicates an expected call of ListConsumerGroupOffsets

func (*MockClusterAdminMockRecorder) ListConsumerGroups added in v0.1.74 

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

ListConsumerGroups indicates an expected call of ListConsumerGroups

func (*MockClusterAdminMockRecorder) ListTopics added in v0.1.74 

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

ListTopics indicates an expected call of ListTopics

type MockFlowKafka 

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

MockFlowKafka is a mock of FlowKafka interface

func NewMockFlowKafka 

func NewMockFlowKafka(ctrl *gomock.Controller) *MockFlowKafka

NewMockFlowKafka creates a new mock instance

func (*MockFlowKafka) CreateTopic 

func (m *MockFlowKafka) CreateTopic(topic string, numPartitions, replicationFactor int, retentionMs string) error

CreateTopic mocks base method

func (*MockFlowKafka) DeleteTopic 

func (m *MockFlowKafka) DeleteTopic(topic string) error

DeleteTopic mocks base method

func (*MockFlowKafka) DescribeTopic 

func (m *MockFlowKafka) DescribeTopic(topic string) (*pkg.Topic, error)

DescribeTopic mocks base method

func (*MockFlowKafka) EXPECT 

func (m *MockFlowKafka) EXPECT() *MockFlowKafkaMockRecorder

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

func (*MockFlowKafka) Produce 

func (m *MockFlowKafka) Produce(topic string, msg []byte) error

Produce mocks base method

type MockFlowKafkaMockRecorder 

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

MockFlowKafkaMockRecorder is the mock recorder for MockFlowKafka

func (*MockFlowKafkaMockRecorder) CreateTopic 

func (mr *MockFlowKafkaMockRecorder) CreateTopic(topic, numPartitions, replicationFactor, retentionMs interface{}) *gomock.Call

CreateTopic indicates an expected call of CreateTopic

func (*MockFlowKafkaMockRecorder) DeleteTopic 

func (mr *MockFlowKafkaMockRecorder) DeleteTopic(topic interface{}) *gomock.Call

DeleteTopic indicates an expected call of DeleteTopic

func (*MockFlowKafkaMockRecorder) DescribeTopic 

func (mr *MockFlowKafkaMockRecorder) DescribeTopic(topic interface{}) *gomock.Call

DescribeTopic indicates an expected call of DescribeTopic

func (*MockFlowKafkaMockRecorder) Produce 

func (mr *MockFlowKafkaMockRecorder) Produce(topic, msg interface{}) *gomock.Call

Produce indicates an expected call of Produce

type MockFlowMSK added in v0.1.73 

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

MockFlowMSK is a mock of FlowMSK interface

func NewMockFlowMSK added in v0.1.73 

func NewMockFlowMSK(ctrl *gomock.Controller) *MockFlowMSK

NewMockFlowMSK creates a new mock instance

func (*MockFlowMSK) EXPECT added in v0.1.73 

func (m *MockFlowMSK) EXPECT() *MockFlowMSKMockRecorder

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

func (*MockFlowMSK) GetBootstrapBrokers added in v0.1.73 

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

GetBootstrapBrokers mocks base method

func (*MockFlowMSK) GetClusterArn added in v0.1.73 

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

GetClusterArn mocks base method

type MockFlowMSKMockRecorder added in v0.1.73 

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

MockFlowMSKMockRecorder is the mock recorder for MockFlowMSK

func (*MockFlowMSKMockRecorder) GetBootstrapBrokers added in v0.1.73 

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

GetBootstrapBrokers indicates an expected call of GetBootstrapBrokers

func (*MockFlowMSKMockRecorder) GetClusterArn added in v0.1.73 

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.