mockdialer

Documentation

Overview

Package mockdialer is a generated GoMock package.

Index

• type MockConsumer
  • func NewMockConsumer(ctrl *gomock.Controller) *MockConsumer
  • func (m *MockConsumer) Close() error
  • func (m *MockConsumer) CommitMessages(ctx context.Context, messages ...kafka.Message) error
  • func (m *MockConsumer) EXPECT() *MockConsumerMockRecorder
  • func (m *MockConsumer) FetchMessage(ctx context.Context) (kafka.Message, error)
  • func (m *MockConsumer) ReadMessage(ctx context.Context) (kafka.Message, error)
• type MockConsumerMockRecorder
  • func (mr *MockConsumerMockRecorder) Close() *gomock.Call
  • func (mr *MockConsumerMockRecorder) CommitMessages(ctx interface{}, messages ...interface{}) *gomock.Call
  • func (mr *MockConsumerMockRecorder) FetchMessage(ctx interface{}) *gomock.Call
  • func (mr *MockConsumerMockRecorder) ReadMessage(ctx interface{}) *gomock.Call

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

func (m *MockConsumer) Close() error

Close mocks base method.

func (*MockConsumer) CommitMessages

func (m *MockConsumer) CommitMessages(ctx context.Context, messages ...kafka.Message) error

CommitMessages mocks base method.

func (*MockConsumer) EXPECT

func (m *MockConsumer) EXPECT() *MockConsumerMockRecorder

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

func (*MockConsumer) FetchMessage

func (m *MockConsumer) FetchMessage(ctx context.Context) (kafka.Message, error)

FetchMessage mocks base method.

func (*MockConsumer) ReadMessage

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

ReadMessage mocks base method.

type MockConsumerMockRecorder

type MockConsumerMockRecorder struct {
	// contains filtered or unexported fields
}

MockConsumerMockRecorder is the mock recorder for MockConsumer.

func (*MockConsumerMockRecorder) Close

func (mr *MockConsumerMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockConsumerMockRecorder) CommitMessages

func (mr *MockConsumerMockRecorder) CommitMessages(ctx interface{}, messages ...interface{}) *gomock.Call

CommitMessages indicates an expected call of CommitMessages.

func (*MockConsumerMockRecorder) FetchMessage

func (mr *MockConsumerMockRecorder) FetchMessage(ctx interface{}) *gomock.Call

FetchMessage indicates an expected call of FetchMessage.

func (*MockConsumerMockRecorder) ReadMessage

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

ReadMessage indicates an expected call of ReadMessage.