mock

package
v0.13.7 Latest Latest
Warning

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

 Go to latest Published: Jan 7, 2021 License: MIT Imports: 4 Imported by: 0

Documentation

Overview

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockClusterConsumer 

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

MockClusterConsumer is a mock of ClusterConsumer interface

func NewMockClusterConsumer 

func NewMockClusterConsumer(ctrl *gomock.Controller) *MockClusterConsumer

NewMockClusterConsumer creates a new mock instance

func (*MockClusterConsumer) Close 

func (m *MockClusterConsumer) Close() error

Close mocks base method

func (*MockClusterConsumer) EXPECT 

func (m *MockClusterConsumer) EXPECT() *MockClusterConsumerMockRecorder

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

func (*MockClusterConsumer) Errors 

func (m *MockClusterConsumer) Errors() <-chan error

Errors mocks base method

func (*MockClusterConsumer) MarkOffset 

func (m *MockClusterConsumer) MarkOffset(msg *sarama.ConsumerMessage, metadata string)

MarkOffset mocks base method

func (*MockClusterConsumer) Messages 

func (m *MockClusterConsumer) Messages() <-chan *sarama.ConsumerMessage

Messages mocks base method

func (*MockClusterConsumer) Notifications 

func (m *MockClusterConsumer) Notifications() <-chan *sarama_cluster.Notification

Notifications mocks base method

type MockClusterConsumerMockRecorder 

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

MockClusterConsumerMockRecorder is the mock recorder for MockClusterConsumer

func (*MockClusterConsumerMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockClusterConsumerMockRecorder) Errors 

func (mr *MockClusterConsumerMockRecorder) Errors() *gomock.Call

Errors indicates an expected call of Errors

func (*MockClusterConsumerMockRecorder) MarkOffset 

func (mr *MockClusterConsumerMockRecorder) MarkOffset(msg, metadata interface{}) *gomock.Call

MarkOffset indicates an expected call of MarkOffset

func (*MockClusterConsumerMockRecorder) Messages 

func (mr *MockClusterConsumerMockRecorder) Messages() *gomock.Call

Messages indicates an expected call of Messages

func (*MockClusterConsumerMockRecorder) Notifications 

func (mr *MockClusterConsumerMockRecorder) Notifications() *gomock.Call

Notifications indicates an expected call of Notifications

type MockConsumerWorker 

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

MockConsumerWorker is a mock of ConsumerWorker interface

func NewMockConsumerWorker 

func NewMockConsumerWorker(ctrl *gomock.Controller) *MockConsumerWorker

NewMockConsumerWorker creates a new mock instance

func (*MockConsumerWorker) EXPECT 

func (m *MockConsumerWorker) EXPECT() *MockConsumerWorkerMockRecorder

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

func (*MockConsumerWorker) Halt 

func (m *MockConsumerWorker) Halt()

Start mocks base method

func (*MockConsumerWorker) IsHalt 

func (m *MockConsumerWorker) IsHalt() bool

IsHalt mocks base method

func (*MockConsumerWorker) IsStart 

func (m *MockConsumerWorker) IsStart() bool

IsStart mocks base method

func (*MockConsumerWorker) OnError 

func (m *MockConsumerWorker) OnError(f func(error))

OnError mocks base method

func (*MockConsumerWorker) OnHalt 

func (m *MockConsumerWorker) OnHalt(f func())

OnHalt mocks base method

func (*MockConsumerWorker) OnNotification 

func (m *MockConsumerWorker) OnNotification(f func(*sarama_cluster.Notification))

OnNotification mocks base method

func (*MockConsumerWorker) OnSuccess 

func (m *MockConsumerWorker) OnSuccess(f func(*sarama.ConsumerMessage))

OnSuccess mocks base method

func (*MockConsumerWorker) Start 

func (m *MockConsumerWorker) Start()

Start mocks base method

func (*MockConsumerWorker) Stop 

func (m *MockConsumerWorker) Stop()

Stop mocks base method

type MockConsumerWorkerMockRecorder 

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

MockConsumerWorkerMockRecorder is the mock recorder for MockConsumerWorker

func (*MockConsumerWorkerMockRecorder) Halt 

func (mr *MockConsumerWorkerMockRecorder) Halt() *gomock.Call

Start indicates an expected call of Start

func (*MockConsumerWorkerMockRecorder) IsHalt 

func (mr *MockConsumerWorkerMockRecorder) IsHalt() *gomock.Call

IsStart indicates an expected call of IsStart

func (*MockConsumerWorkerMockRecorder) IsStart 

func (mr *MockConsumerWorkerMockRecorder) IsStart() *gomock.Call

IsStart indicates an expected call of IsStart

func (*MockConsumerWorkerMockRecorder) OnError 

func (mr *MockConsumerWorkerMockRecorder) OnError(f interface{}) *gomock.Call

OnError indicates an expected call of OnError

func (*MockConsumerWorkerMockRecorder) OnNotification 

func (mr *MockConsumerWorkerMockRecorder) OnNotification(f interface{}) *gomock.Call

OnNotification indicates an expected call of OnNotification

func (*MockConsumerWorkerMockRecorder) OnSuccess 

func (mr *MockConsumerWorkerMockRecorder) OnSuccess(f interface{}) *gomock.Call

OnSuccess indicates an expected call of OnSuccess

func (*MockConsumerWorkerMockRecorder) Start 

func (mr *MockConsumerWorkerMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start

func (*MockConsumerWorkerMockRecorder) Stop 

func (mr *MockConsumerWorkerMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop

type MockKafkaAdmin 

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

MockKafkaAdmin is a mock of KafkaAdmin interface

func NewMockKafkaAdmin 

func NewMockKafkaAdmin(ctrl *gomock.Controller) *MockKafkaAdmin

NewMockKafkaAdmin creates a new mock instance

func (*MockKafkaAdmin) AddTopic 

func (m *MockKafkaAdmin) AddTopic(topic string)

AddTopic mocks base method

func (*MockKafkaAdmin) Close 

func (m *MockKafkaAdmin) Close()

Close mocks base method

func (*MockKafkaAdmin) CreateTopic 

func (m *MockKafkaAdmin) CreateTopic(topic string, numPartitions int32, replicationFactor int16) error

CreateTopic mocks base method

func (*MockKafkaAdmin) EXPECT 

func (m *MockKafkaAdmin) EXPECT() *MockKafkaAdminMockRecorder

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

func (*MockKafkaAdmin) Exist 

func (m *MockKafkaAdmin) Exist(topic string) bool

Exist mocks base method

func (*MockKafkaAdmin) RefreshTopics 

func (m *MockKafkaAdmin) RefreshTopics() error

RefreshTopics mocks base method

func (*MockKafkaAdmin) SetTopics 

func (m *MockKafkaAdmin) SetTopics(arg0 []string)

SetTopics mocks base method

func (*MockKafkaAdmin) Topics 

func (m *MockKafkaAdmin) Topics() []string

Topics mocks base method

func (*MockKafkaAdmin) TopicsWithSuffix 

func (m *MockKafkaAdmin) TopicsWithSuffix(suffix string) []string

TopicsWithSuffix mocks base method

type MockKafkaAdminMockRecorder 

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

MockKafkaAdminMockRecorder is the mock recorder for MockKafkaAdmin

func (*MockKafkaAdminMockRecorder) AddTopic 

func (mr *MockKafkaAdminMockRecorder) AddTopic(topic interface{}) *gomock.Call

AddTopic indicates an expected call of AddTopic

func (*MockKafkaAdminMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockKafkaAdminMockRecorder) CreateTopic 

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

CreateTopic indicates an expected call of CreateTopic

func (*MockKafkaAdminMockRecorder) Exist 

func (mr *MockKafkaAdminMockRecorder) Exist(topic interface{}) *gomock.Call

Exist indicates an expected call of Exist

func (*MockKafkaAdminMockRecorder) RefreshTopics 

func (mr *MockKafkaAdminMockRecorder) RefreshTopics() *gomock.Call

RefreshTopics indicates an expected call of RefreshTopics

func (*MockKafkaAdminMockRecorder) SetTopics 

func (mr *MockKafkaAdminMockRecorder) SetTopics(arg0 interface{}) *gomock.Call

SetTopics indicates an expected call of SetTopics

func (*MockKafkaAdminMockRecorder) Topics 

func (mr *MockKafkaAdminMockRecorder) Topics() *gomock.Call

Topics indicates an expected call of Topics

func (*MockKafkaAdminMockRecorder) TopicsWithSuffix 

func (mr *MockKafkaAdminMockRecorder) TopicsWithSuffix(suffix interface{}) *gomock.Call

TopicsWithSuffix indicates an expected call of TopicsWithSuffix

type MockSyncProducer 

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

MockSyncProducer is a mock of SyncProducer interface

func NewMockSyncProducer 

func NewMockSyncProducer(ctrl *gomock.Controller) *MockSyncProducer

NewMockSyncProducer creates a new mock instance

func (*MockSyncProducer) Close 

func (m *MockSyncProducer) Close() error

Close mocks base method

func (*MockSyncProducer) EXPECT 

func (m *MockSyncProducer) EXPECT() *MockSyncProducerMockRecorder

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

func (*MockSyncProducer) SendMessage 

func (m *MockSyncProducer) SendMessage(msg *sarama.ProducerMessage) (int32, int64, error)

SendMessage mocks base method

func (*MockSyncProducer) SendMessages 

func (m *MockSyncProducer) SendMessages(msgs []*sarama.ProducerMessage) error

SendMessages mocks base method

type MockSyncProducerMockRecorder 

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

MockSyncProducerMockRecorder is the mock recorder for MockSyncProducer

func (*MockSyncProducerMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockSyncProducerMockRecorder) SendMessage 

func (mr *MockSyncProducerMockRecorder) SendMessage(msg interface{}) *gomock.Call

SendMessage indicates an expected call of SendMessage

func (*MockSyncProducerMockRecorder) SendMessages 

func (mr *MockSyncProducerMockRecorder) SendMessages(msgs interface{}) *gomock.Call

SendMessages indicates an expected call of SendMessages

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.