mocks

Documentation

Overview

Package mocks is a generated GoMock package.

Index

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

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

func (m *MockConsumer) Shutdown() error

Shutdown mocks base method.

func (*MockConsumer) Start

func (m *MockConsumer) Start() error

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