Documentation
¶
Overview ¶
Package mocks is a generated GoMock package.
Index ¶
- type MockConsumer
- func (m *MockConsumer) EXPECT() *MockConsumerMockRecorder
- func (m *MockConsumer) Init(arg0 map[string]string) error
- func (m *MockConsumer) RegisterListener(arg0 *connector.EventListener)
- func (m *MockConsumer) Shutdown() error
- func (m *MockConsumer) Start() error
- func (m *MockConsumer) Subscribe(arg0 string) error
- func (m *MockConsumer) UnSubscribe(arg0 string) error
- func (m *MockConsumer) UpdateOffset(arg0 context.Context, arg1 []*event.Event)
- type MockConsumerMockRecorder
- func (mr *MockConsumerMockRecorder) Init(arg0 interface{}) *gomock.Call
- func (mr *MockConsumerMockRecorder) RegisterListener(arg0 interface{}) *gomock.Call
- func (mr *MockConsumerMockRecorder) Shutdown() *gomock.Call
- func (mr *MockConsumerMockRecorder) Start() *gomock.Call
- func (mr *MockConsumerMockRecorder) Subscribe(arg0 interface{}) *gomock.Call
- func (mr *MockConsumerMockRecorder) UnSubscribe(arg0 interface{}) *gomock.Call
- func (mr *MockConsumerMockRecorder) UpdateOffset(arg0, arg1 interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockConsumer ¶
type MockConsumer struct {
// contains filtered or unexported fields
}
MockConsumer is a mock of Consumer interface.
func NewMockConsumer ¶
func NewMockConsumer(ctrl *gomock.Controller) *MockConsumer
NewMockConsumer creates a new mock instance.
func (*MockConsumer) EXPECT ¶
func (m *MockConsumer) EXPECT() *MockConsumerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockConsumer) Init ¶
func (m *MockConsumer) Init(arg0 map[string]string) error
Init mocks base method.
func (*MockConsumer) RegisterListener ¶
func (m *MockConsumer) RegisterListener(arg0 *connector.EventListener)
RegisterListener mocks base method.
func (*MockConsumer) Subscribe ¶
func (m *MockConsumer) Subscribe(arg0 string) error
Subscribe mocks base method.
func (*MockConsumer) UnSubscribe ¶
func (m *MockConsumer) UnSubscribe(arg0 string) error
UnSubscribe mocks base method.
func (*MockConsumer) UpdateOffset ¶
func (m *MockConsumer) UpdateOffset(arg0 context.Context, arg1 []*event.Event)
UpdateOffset mocks base method.
type MockConsumerMockRecorder ¶
type MockConsumerMockRecorder struct {
// contains filtered or unexported fields
}
MockConsumerMockRecorder is the mock recorder for MockConsumer.
func (*MockConsumerMockRecorder) Init ¶
func (mr *MockConsumerMockRecorder) Init(arg0 interface{}) *gomock.Call
Init indicates an expected call of Init.
func (*MockConsumerMockRecorder) RegisterListener ¶
func (mr *MockConsumerMockRecorder) RegisterListener(arg0 interface{}) *gomock.Call
RegisterListener indicates an expected call of RegisterListener.
func (*MockConsumerMockRecorder) Shutdown ¶
func (mr *MockConsumerMockRecorder) Shutdown() *gomock.Call
Shutdown indicates an expected call of Shutdown.
func (*MockConsumerMockRecorder) Start ¶
func (mr *MockConsumerMockRecorder) Start() *gomock.Call
Start indicates an expected call of Start.
func (*MockConsumerMockRecorder) Subscribe ¶
func (mr *MockConsumerMockRecorder) Subscribe(arg0 interface{}) *gomock.Call
Subscribe indicates an expected call of Subscribe.
func (*MockConsumerMockRecorder) UnSubscribe ¶
func (mr *MockConsumerMockRecorder) UnSubscribe(arg0 interface{}) *gomock.Call
UnSubscribe indicates an expected call of UnSubscribe.
func (*MockConsumerMockRecorder) UpdateOffset ¶
func (mr *MockConsumerMockRecorder) UpdateOffset(arg0, arg1 interface{}) *gomock.Call
UpdateOffset indicates an expected call of UpdateOffset.
Source Files