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 ¶
- type MockClusterConsumer
- func (m *MockClusterConsumer) Close() error
- func (m *MockClusterConsumer) EXPECT() *MockClusterConsumerMockRecorder
- func (m *MockClusterConsumer) Errors() <-chan error
- func (m *MockClusterConsumer) MarkOffset(msg *sarama.ConsumerMessage, metadata string)
- func (m *MockClusterConsumer) Messages() <-chan *sarama.ConsumerMessage
- func (m *MockClusterConsumer) Notifications() <-chan *sarama_cluster.Notification
- type MockClusterConsumerMockRecorder
- func (mr *MockClusterConsumerMockRecorder) Close() *gomock.Call
- func (mr *MockClusterConsumerMockRecorder) Errors() *gomock.Call
- func (mr *MockClusterConsumerMockRecorder) MarkOffset(msg, metadata interface{}) *gomock.Call
- func (mr *MockClusterConsumerMockRecorder) Messages() *gomock.Call
- func (mr *MockClusterConsumerMockRecorder) Notifications() *gomock.Call
- type MockConsumerWorker
- func (m *MockConsumerWorker) EXPECT() *MockConsumerWorkerMockRecorder
- func (m *MockConsumerWorker) Halt()
- func (m *MockConsumerWorker) IsHalt() bool
- func (m *MockConsumerWorker) IsStart() bool
- func (m *MockConsumerWorker) OnError(f func(error))
- func (m *MockConsumerWorker) OnHalt(f func())
- func (m *MockConsumerWorker) OnNotification(f func(*sarama_cluster.Notification))
- func (m *MockConsumerWorker) OnSuccess(f func(*sarama.ConsumerMessage))
- func (m *MockConsumerWorker) Start()
- func (m *MockConsumerWorker) Stop()
- type MockConsumerWorkerMockRecorder
- func (mr *MockConsumerWorkerMockRecorder) Halt() *gomock.Call
- func (mr *MockConsumerWorkerMockRecorder) IsHalt() *gomock.Call
- func (mr *MockConsumerWorkerMockRecorder) IsStart() *gomock.Call
- func (mr *MockConsumerWorkerMockRecorder) OnError(f interface{}) *gomock.Call
- func (mr *MockConsumerWorkerMockRecorder) OnNotification(f interface{}) *gomock.Call
- func (mr *MockConsumerWorkerMockRecorder) OnSuccess(f interface{}) *gomock.Call
- func (mr *MockConsumerWorkerMockRecorder) Start() *gomock.Call
- func (mr *MockConsumerWorkerMockRecorder) Stop() *gomock.Call
- type MockKafkaAdmin
- func (m *MockKafkaAdmin) AddTopic(topic string)
- func (m *MockKafkaAdmin) Close()
- func (m *MockKafkaAdmin) CreateTopic(topic string, numPartitions int32, replicationFactor int16) error
- func (m *MockKafkaAdmin) EXPECT() *MockKafkaAdminMockRecorder
- func (m *MockKafkaAdmin) Exist(topic string) bool
- func (m *MockKafkaAdmin) RefreshTopics() error
- func (m *MockKafkaAdmin) SetTopics(arg0 []string)
- func (m *MockKafkaAdmin) Topics() []string
- func (m *MockKafkaAdmin) TopicsWithSuffix(suffix string) []string
- type MockKafkaAdminMockRecorder
- func (mr *MockKafkaAdminMockRecorder) AddTopic(topic interface{}) *gomock.Call
- func (mr *MockKafkaAdminMockRecorder) Close() *gomock.Call
- func (mr *MockKafkaAdminMockRecorder) CreateTopic(topic, numPartitions, replicationFactor interface{}) *gomock.Call
- func (mr *MockKafkaAdminMockRecorder) Exist(topic interface{}) *gomock.Call
- func (mr *MockKafkaAdminMockRecorder) RefreshTopics() *gomock.Call
- func (mr *MockKafkaAdminMockRecorder) SetTopics(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAdminMockRecorder) Topics() *gomock.Call
- func (mr *MockKafkaAdminMockRecorder) TopicsWithSuffix(suffix interface{}) *gomock.Call
- type MockSyncProducer
- type MockSyncProducerMockRecorder
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) 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
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) 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) 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) 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