mock

Documentation

Overview

Package mock is a generated GoMock package.

Index

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

Types

type MockScheduler

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

MockScheduler is a mock of Scheduler interface.

func NewMockScheduler

func NewMockScheduler(ctrl *gomock.Controller) *MockScheduler

NewMockScheduler creates a new mock instance.

func (*MockScheduler) Close

func (m *MockScheduler) Close() error

Close mocks base method.

func (*MockScheduler) EXPECT

func (m *MockScheduler) EXPECT() *MockSchedulerMockRecorder

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

func (*MockScheduler) NewConsumer

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

NewConsumer mocks base method.

func (*MockScheduler) Produce

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

Produce mocks base method.

func (*MockScheduler) Run

func (m *MockScheduler) Run()

Run mocks base method.

type MockSchedulerMockRecorder

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

MockSchedulerMockRecorder is the mock recorder for MockScheduler.

func (*MockSchedulerMockRecorder) Close

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

Close indicates an expected call of Close.

func (*MockSchedulerMockRecorder) NewConsumer

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

NewConsumer indicates an expected call of NewConsumer.

func (*MockSchedulerMockRecorder) Produce

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

Produce indicates an expected call of Produce.

func (*MockSchedulerMockRecorder) Run

func (mr *MockSchedulerMockRecorder) Run() *gomock.Call

Run indicates an expected call of Run.