mock

Documentation

Overview

Package mock is a generated GoMock package.

Index

• type MockRealTimeConnector
  • func NewMockRealTimeConnector(ctrl *gomock.Controller) *MockRealTimeConnector
  • func (m *MockRealTimeConnector) Close() error
  • func (m *MockRealTimeConnector) EXPECT() *MockRealTimeConnectorMockRecorder
  • func (m *MockRealTimeConnector) NewConsumer(topic, group string, batchSize int, fn types0.HandleMessage) error
  • func (m *MockRealTimeConnector) Produce(ctx context.Context, msg *types.Message) error
• type MockRealTimeConnectorMockRecorder
  • func (mr *MockRealTimeConnectorMockRecorder) Close() *gomock.Call
  • func (mr *MockRealTimeConnectorMockRecorder) NewConsumer(topic, group, batchSize, fn interface{}) *gomock.Call
  • func (mr *MockRealTimeConnectorMockRecorder) Produce(ctx, msg interface{}) *gomock.Call

Types

type MockRealTimeConnector

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

MockRealTimeConnector is a mock of RealTimeConnector interface.

func NewMockRealTimeConnector

func NewMockRealTimeConnector(ctrl *gomock.Controller) *MockRealTimeConnector

NewMockRealTimeConnector creates a new mock instance.

func (*MockRealTimeConnector) Close

func (m *MockRealTimeConnector) Close() error

Close mocks base method.

func (*MockRealTimeConnector) EXPECT

func (m *MockRealTimeConnector) EXPECT() *MockRealTimeConnectorMockRecorder

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

func (*MockRealTimeConnector) NewConsumer

func (m *MockRealTimeConnector) NewConsumer(topic, group string, batchSize int, fn types0.HandleMessage) error

NewConsumer mocks base method.

func (*MockRealTimeConnector) Produce

func (m *MockRealTimeConnector) Produce(ctx context.Context, msg *types.Message) error

Produce mocks base method.

type MockRealTimeConnectorMockRecorder

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

MockRealTimeConnectorMockRecorder is the mock recorder for MockRealTimeConnector.

func (*MockRealTimeConnectorMockRecorder) Close

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

Close indicates an expected call of Close.

func (*MockRealTimeConnectorMockRecorder) NewConsumer

func (mr *MockRealTimeConnectorMockRecorder) NewConsumer(topic, group, batchSize, fn interface{}) *gomock.Call

NewConsumer indicates an expected call of NewConsumer.

func (*MockRealTimeConnectorMockRecorder) Produce

func (mr *MockRealTimeConnectorMockRecorder) Produce(ctx, msg interface{}) *gomock.Call

Produce indicates an expected call of Produce.