kafka

Documentation

Overview

Package kafka is a generated GoMock package.

Index

• type MockReader
  • func NewMockReader(ctrl *gomock.Controller) *MockReader
  • func (m *MockReader) Close() error
  • func (m *MockReader) EXPECT() *MockReaderMockRecorder
  • func (m *MockReader) ReadMessage(ctx context.Context) (kafka.Message, error)
• type MockReaderMockRecorder
  • func (mr *MockReaderMockRecorder) Close() *gomock.Call
  • func (mr *MockReaderMockRecorder) ReadMessage(ctx interface{}) *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) EXPECT

func (m *MockReader) EXPECT() *MockReaderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockReader) ReadMessage

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

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

func (mr *MockReaderMockRecorder) ReadMessage(ctx interface{}) *gomock.Call

ReadMessage indicates an expected call of ReadMessage.