mock

Documentation

Overview

Package mock is a generated GoMock package.

Index

• type MockReader
  • func NewMockReader(ctrl *gomock.Controller) *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

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) Close

func (m *MockReader) Close() error

Close mocks base method.

func (*MockReader) CommitMessages

func (m *MockReader) CommitMessages(arg0 context.Context, arg1 ...kafka.Message) error

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

func (m *MockReader) FetchMessage(arg0 context.Context) (kafka.Message, error)

FetchMessage mocks base method.

func (*MockReader) Lag

func (m *MockReader) Lag() int64

Lag mocks base method.

func (*MockReader) Offset

func (m *MockReader) Offset() int64

Offset mocks base method.

func (*MockReader) ReadLag

func (m *MockReader) ReadLag(arg0 context.Context) (int64, error)

ReadLag mocks base method.

func (*MockReader) ReadMessage

func (m *MockReader) ReadMessage(arg0 context.Context) (kafka.Message, error)

ReadMessage mocks base method.

func (*MockReader) SetOffset

func (m *MockReader) SetOffset(arg0 int64) error

SetOffset mocks base method.

func (*MockReader) SetOffsetAt

func (m *MockReader) SetOffsetAt(arg0 context.Context, arg1 time.Time) error

SetOffsetAt mocks base method.

func (*MockReader) Stats

func (m *MockReader) Stats() kafka.ReaderStats

Stats 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.