Documentation
¶
Overview ¶
Package mock is a generated GoMock package.
Index ¶
- type MockReader
- func (m *MockReader) Close() error
- func (m *MockReader) CommitMessages(arg0 context.Context, arg1 ...kafka.Message) error
- func (m *MockReader) Config() kafka.ReaderConfig
- func (m *MockReader) EXPECT() *MockReaderMockRecorder
- func (m *MockReader) FetchMessage(arg0 context.Context) (kafka.Message, error)
- func (m *MockReader) Lag() int64
- func (m *MockReader) Offset() int64
- func (m *MockReader) ReadLag(arg0 context.Context) (int64, error)
- func (m *MockReader) ReadMessage(arg0 context.Context) (kafka.Message, error)
- func (m *MockReader) SetOffset(arg0 int64) error
- func (m *MockReader) SetOffsetAt(arg0 context.Context, arg1 time.Time) error
- func (m *MockReader) Stats() kafka.ReaderStats
- type MockReaderMockRecorder
- func (mr *MockReaderMockRecorder) Close() *gomock.Call
- func (mr *MockReaderMockRecorder) CommitMessages(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockReaderMockRecorder) Config() *gomock.Call
- func (mr *MockReaderMockRecorder) FetchMessage(arg0 interface{}) *gomock.Call
- func (mr *MockReaderMockRecorder) Lag() *gomock.Call
- func (mr *MockReaderMockRecorder) Offset() *gomock.Call
- func (mr *MockReaderMockRecorder) ReadLag(arg0 interface{}) *gomock.Call
- func (mr *MockReaderMockRecorder) ReadMessage(arg0 interface{}) *gomock.Call
- func (mr *MockReaderMockRecorder) SetOffset(arg0 interface{}) *gomock.Call
- func (mr *MockReaderMockRecorder) SetOffsetAt(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockReaderMockRecorder) Stats() *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockReader ¶
type MockReader struct {
// contains filtered or unexported fields
}
MockReader is a mock of Reader interface.
func NewMockReader ¶
func NewMockReader(ctrl *gomock.Controller) *MockReader
NewMockReader creates a new mock instance.
func (*MockReader) CommitMessages ¶
CommitMessages mocks base method.
func (*MockReader) Config ¶
func (m *MockReader) Config() kafka.ReaderConfig
Config mocks base method.
func (*MockReader) EXPECT ¶
func (m *MockReader) EXPECT() *MockReaderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockReader) FetchMessage ¶
FetchMessage mocks base method.
func (*MockReader) ReadLag ¶
func (m *MockReader) ReadLag(arg0 context.Context) (int64, error)
ReadLag mocks base method.
func (*MockReader) ReadMessage ¶
ReadMessage mocks base method.
func (*MockReader) SetOffset ¶
func (m *MockReader) SetOffset(arg0 int64) error
SetOffset mocks base method.
func (*MockReader) SetOffsetAt ¶
SetOffsetAt mocks base method.
type MockReaderMockRecorder ¶
type MockReaderMockRecorder struct {
// contains filtered or unexported fields
}
MockReaderMockRecorder is the mock recorder for MockReader.
func (*MockReaderMockRecorder) Close ¶
func (mr *MockReaderMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockReaderMockRecorder) CommitMessages ¶
func (mr *MockReaderMockRecorder) CommitMessages(arg0 interface{}, arg1 ...interface{}) *gomock.Call
CommitMessages indicates an expected call of CommitMessages.
func (*MockReaderMockRecorder) Config ¶
func (mr *MockReaderMockRecorder) Config() *gomock.Call
Config indicates an expected call of Config.
func (*MockReaderMockRecorder) FetchMessage ¶
func (mr *MockReaderMockRecorder) FetchMessage(arg0 interface{}) *gomock.Call
FetchMessage indicates an expected call of FetchMessage.
func (*MockReaderMockRecorder) Lag ¶
func (mr *MockReaderMockRecorder) Lag() *gomock.Call
Lag indicates an expected call of Lag.
func (*MockReaderMockRecorder) Offset ¶
func (mr *MockReaderMockRecorder) Offset() *gomock.Call
Offset indicates an expected call of Offset.
func (*MockReaderMockRecorder) ReadLag ¶
func (mr *MockReaderMockRecorder) ReadLag(arg0 interface{}) *gomock.Call
ReadLag indicates an expected call of ReadLag.
func (*MockReaderMockRecorder) ReadMessage ¶
func (mr *MockReaderMockRecorder) ReadMessage(arg0 interface{}) *gomock.Call
ReadMessage indicates an expected call of ReadMessage.
func (*MockReaderMockRecorder) SetOffset ¶
func (mr *MockReaderMockRecorder) SetOffset(arg0 interface{}) *gomock.Call
SetOffset indicates an expected call of SetOffset.
func (*MockReaderMockRecorder) SetOffsetAt ¶
func (mr *MockReaderMockRecorder) SetOffsetAt(arg0, arg1 interface{}) *gomock.Call
SetOffsetAt indicates an expected call of SetOffsetAt.
func (*MockReaderMockRecorder) Stats ¶
func (mr *MockReaderMockRecorder) Stats() *gomock.Call
Stats indicates an expected call of Stats.
Source Files