Documentation
¶
Overview ¶
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Index ¶
- type MockKPConsumer
- func (m *MockKPConsumer) Cleanup(arg0 sarama.ConsumerGroupSession) error
- func (m *MockKPConsumer) ConsumeClaim(arg0 sarama.ConsumerGroupSession, arg1 sarama.ConsumerGroupClaim) error
- func (m *MockKPConsumer) EXPECT() *MockKPConsumerMockRecorder
- func (m *MockKPConsumer) GetReady() chan bool
- func (m *MockKPConsumer) Process(arg0 context.Context, arg1 *sarama.ConsumerMessage) error
- func (m *MockKPConsumer) SetReady(arg0 chan bool)
- func (m *MockKPConsumer) Setup(arg0 sarama.ConsumerGroupSession) error
- type MockKPConsumerMockRecorder
- func (mr *MockKPConsumerMockRecorder) Cleanup(arg0 interface{}) *gomock.Call
- func (mr *MockKPConsumerMockRecorder) ConsumeClaim(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockKPConsumerMockRecorder) GetReady() *gomock.Call
- func (mr *MockKPConsumerMockRecorder) Process(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockKPConsumerMockRecorder) SetReady(arg0 interface{}) *gomock.Call
- func (mr *MockKPConsumerMockRecorder) Setup(arg0 interface{}) *gomock.Call
- type MockKPProducer
- type MockKPProducerMockRecorder
- type MockKafkaProcessor
- func (m *MockKafkaProcessor) EXPECT() *MockKafkaProcessorMockRecorder
- func (m *MockKafkaProcessor) OnFailure(arg0 func(context.Context, string, string, int, *sarama.ConsumerMessage) error)
- func (m *MockKafkaProcessor) Process(arg0 func(context.Context, string, string, int, *sarama.ConsumerMessage) error)
- func (m *MockKafkaProcessor) Start(arg0 context.Context) error
- func (m *MockKafkaProcessor) Stop()
- type MockKafkaProcessorMockRecorder
- func (mr *MockKafkaProcessorMockRecorder) OnFailure(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaProcessorMockRecorder) Process(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaProcessorMockRecorder) Start(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaProcessorMockRecorder) Stop() *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockKPConsumer ¶
type MockKPConsumer struct {
// contains filtered or unexported fields
}
MockKPConsumer is a mock of KPConsumer interface.
func NewMockKPConsumer ¶
func NewMockKPConsumer(ctrl *gomock.Controller) *MockKPConsumer
NewMockKPConsumer creates a new mock instance.
func (*MockKPConsumer) Cleanup ¶
func (m *MockKPConsumer) Cleanup(arg0 sarama.ConsumerGroupSession) error
Cleanup mocks base method.
func (*MockKPConsumer) ConsumeClaim ¶
func (m *MockKPConsumer) ConsumeClaim(arg0 sarama.ConsumerGroupSession, arg1 sarama.ConsumerGroupClaim) error
ConsumeClaim mocks base method.
func (*MockKPConsumer) EXPECT ¶
func (m *MockKPConsumer) EXPECT() *MockKPConsumerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockKPConsumer) GetReady ¶
func (m *MockKPConsumer) GetReady() chan bool
GetReady mocks base method.
func (*MockKPConsumer) Process ¶
func (m *MockKPConsumer) Process(arg0 context.Context, arg1 *sarama.ConsumerMessage) error
Process mocks base method.
func (*MockKPConsumer) SetReady ¶
func (m *MockKPConsumer) SetReady(arg0 chan bool)
SetReady mocks base method.
func (*MockKPConsumer) Setup ¶
func (m *MockKPConsumer) Setup(arg0 sarama.ConsumerGroupSession) error
Setup mocks base method.
type MockKPConsumerMockRecorder ¶
type MockKPConsumerMockRecorder struct {
// contains filtered or unexported fields
}
MockKPConsumerMockRecorder is the mock recorder for MockKPConsumer.
func (*MockKPConsumerMockRecorder) Cleanup ¶
func (mr *MockKPConsumerMockRecorder) Cleanup(arg0 interface{}) *gomock.Call
Cleanup indicates an expected call of Cleanup.
func (*MockKPConsumerMockRecorder) ConsumeClaim ¶
func (mr *MockKPConsumerMockRecorder) ConsumeClaim(arg0, arg1 interface{}) *gomock.Call
ConsumeClaim indicates an expected call of ConsumeClaim.
func (*MockKPConsumerMockRecorder) GetReady ¶
func (mr *MockKPConsumerMockRecorder) GetReady() *gomock.Call
GetReady indicates an expected call of GetReady.
func (*MockKPConsumerMockRecorder) Process ¶
func (mr *MockKPConsumerMockRecorder) Process(arg0, arg1 interface{}) *gomock.Call
Process indicates an expected call of Process.
func (*MockKPConsumerMockRecorder) SetReady ¶
func (mr *MockKPConsumerMockRecorder) SetReady(arg0 interface{}) *gomock.Call
SetReady indicates an expected call of SetReady.
func (*MockKPConsumerMockRecorder) Setup ¶
func (mr *MockKPConsumerMockRecorder) Setup(arg0 interface{}) *gomock.Call
Setup indicates an expected call of Setup.
type MockKPProducer ¶
type MockKPProducer struct {
// contains filtered or unexported fields
}
MockKPProducer is a mock of KPProducer interface.
func NewMockKPProducer ¶
func NewMockKPProducer(ctrl *gomock.Controller) *MockKPProducer
NewMockKPProducer creates a new mock instance.
func (*MockKPProducer) EXPECT ¶
func (m *MockKPProducer) EXPECT() *MockKPProducerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockKPProducer) GetProducer ¶
func (m *MockKPProducer) GetProducer(arg0 kp.KafkaConfig) *kp.Producer
GetProducer mocks base method.
func (*MockKPProducer) ProduceMessage ¶
func (m *MockKPProducer) ProduceMessage(arg0 context.Context, arg1, arg2, arg3 string) error
ProduceMessage mocks base method.
type MockKPProducerMockRecorder ¶
type MockKPProducerMockRecorder struct {
// contains filtered or unexported fields
}
MockKPProducerMockRecorder is the mock recorder for MockKPProducer.
func (*MockKPProducerMockRecorder) GetProducer ¶
func (mr *MockKPProducerMockRecorder) GetProducer(arg0 interface{}) *gomock.Call
GetProducer indicates an expected call of GetProducer.
func (*MockKPProducerMockRecorder) ProduceMessage ¶
func (mr *MockKPProducerMockRecorder) ProduceMessage(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
ProduceMessage indicates an expected call of ProduceMessage.
type MockKafkaProcessor ¶
type MockKafkaProcessor struct {
// contains filtered or unexported fields
}
MockKafkaProcessor is a mock of KafkaProcessor interface.
func NewMockKafkaProcessor ¶
func NewMockKafkaProcessor(ctrl *gomock.Controller) *MockKafkaProcessor
NewMockKafkaProcessor creates a new mock instance.
func (*MockKafkaProcessor) EXPECT ¶
func (m *MockKafkaProcessor) EXPECT() *MockKafkaProcessorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockKafkaProcessor) OnFailure ¶
func (m *MockKafkaProcessor) OnFailure(arg0 func(context.Context, string, string, int, *sarama.ConsumerMessage) error)
OnFailure mocks base method.
func (*MockKafkaProcessor) Process ¶
func (m *MockKafkaProcessor) Process(arg0 func(context.Context, string, string, int, *sarama.ConsumerMessage) error)
Process mocks base method.
type MockKafkaProcessorMockRecorder ¶
type MockKafkaProcessorMockRecorder struct {
// contains filtered or unexported fields
}
MockKafkaProcessorMockRecorder is the mock recorder for MockKafkaProcessor.
func (*MockKafkaProcessorMockRecorder) OnFailure ¶
func (mr *MockKafkaProcessorMockRecorder) OnFailure(arg0 interface{}) *gomock.Call
OnFailure indicates an expected call of OnFailure.
func (*MockKafkaProcessorMockRecorder) Process ¶
func (mr *MockKafkaProcessorMockRecorder) Process(arg0 interface{}) *gomock.Call
Process indicates an expected call of Process.
func (*MockKafkaProcessorMockRecorder) Start ¶
func (mr *MockKafkaProcessorMockRecorder) Start(arg0 interface{}) *gomock.Call
Start indicates an expected call of Start.
func (*MockKafkaProcessorMockRecorder) Stop ¶
func (mr *MockKafkaProcessorMockRecorder) Stop() *gomock.Call
Stop indicates an expected call of Stop.
Source Files