asynqengine

package
v0.1.270-asynq-engine.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 30, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package asynqengine is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockIMiniRedisTaskClient

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

MockIMiniRedisTaskClient is a mock of IMiniRedisTaskClient interface.

func NewMockIMiniRedisTaskClient

func NewMockIMiniRedisTaskClient(ctrl *gomock.Controller) *MockIMiniRedisTaskClient

NewMockIMiniRedisTaskClient creates a new mock instance.

func (*MockIMiniRedisTaskClient) EXPECT

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

func (*MockIMiniRedisTaskClient) EnqueTask

func (m *MockIMiniRedisTaskClient) EnqueTask(arg0 *asynq.Task, arg1 ...asynq.Option) (*asynq.TaskInfo, error)

EnqueTask mocks base method.

type MockIMiniRedisTaskClientMockRecorder

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

MockIMiniRedisTaskClientMockRecorder is the mock recorder for MockIMiniRedisTaskClient.

func (*MockIMiniRedisTaskClientMockRecorder) EnqueTask

func (mr *MockIMiniRedisTaskClientMockRecorder) EnqueTask(arg0 interface{}, arg1 ...interface{}) *gomock.Call

EnqueTask indicates an expected call of EnqueTask.

type MockIRedisTaskClient

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

MockIRedisTaskClient is a mock of IRedisTaskClient interface.

func NewMockIRedisTaskClient

func NewMockIRedisTaskClient(ctrl *gomock.Controller) *MockIRedisTaskClient

NewMockIRedisTaskClient creates a new mock instance.

func (*MockIRedisTaskClient) EXPECT

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

func (*MockIRedisTaskClient) EnqueTask

func (m *MockIRedisTaskClient) EnqueTask(arg0 *asynq.Task, arg1 ...asynq.Option) (*asynq.TaskInfo, error)

EnqueTask mocks base method.

type MockIRedisTaskClientMockRecorder

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

MockIRedisTaskClientMockRecorder is the mock recorder for MockIRedisTaskClient.

func (*MockIRedisTaskClientMockRecorder) EnqueTask

func (mr *MockIRedisTaskClientMockRecorder) EnqueTask(arg0 interface{}, arg1 ...interface{}) *gomock.Call

EnqueTask indicates an expected call of EnqueTask.

type MockISingletonTask

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

MockISingletonTask is a mock of ISingletonTask interface.

func NewMockISingletonTask

func NewMockISingletonTask(ctrl *gomock.Controller) *MockISingletonTask

NewMockISingletonTask creates a new mock instance.

func (*MockISingletonTask) EXPECT

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

func (*MockISingletonTask) GetPatterns

func (m *MockISingletonTask) GetPatterns() *hashset.StringSet

GetPatterns mocks base method.

func (*MockISingletonTask) ProcessTask

func (m *MockISingletonTask) ProcessTask(arg0 context.Context, arg1 *asynq.Task) error

ProcessTask mocks base method.

type MockISingletonTaskMockRecorder

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

MockISingletonTaskMockRecorder is the mock recorder for MockISingletonTask.

func (*MockISingletonTaskMockRecorder) GetPatterns

func (mr *MockISingletonTaskMockRecorder) GetPatterns() *gomock.Call

GetPatterns indicates an expected call of GetPatterns.

func (*MockISingletonTaskMockRecorder) ProcessTask

func (mr *MockISingletonTaskMockRecorder) ProcessTask(arg0, arg1 interface{}) *gomock.Call

ProcessTask indicates an expected call of ProcessTask.

type MockITaskClient

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

MockITaskClient is a mock of ITaskClient interface.

func NewMockITaskClient

func NewMockITaskClient(ctrl *gomock.Controller) *MockITaskClient

NewMockITaskClient creates a new mock instance.

func (*MockITaskClient) EXPECT

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

func (*MockITaskClient) EnqueTask

func (m *MockITaskClient) EnqueTask(arg0 *asynq.Task, arg1 ...asynq.Option) (*asynq.TaskInfo, error)

EnqueTask mocks base method.

type MockITaskClientMockRecorder

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

MockITaskClientMockRecorder is the mock recorder for MockITaskClient.

func (*MockITaskClientMockRecorder) EnqueTask

func (mr *MockITaskClientMockRecorder) EnqueTask(arg0 interface{}, arg1 ...interface{}) *gomock.Call

EnqueTask indicates an expected call of EnqueTask.

type MockITaskEngineFactory

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

MockITaskEngineFactory is a mock of ITaskEngineFactory interface.

func NewMockITaskEngineFactory

func NewMockITaskEngineFactory(ctrl *gomock.Controller) *MockITaskEngineFactory

NewMockITaskEngineFactory creates a new mock instance.

func (*MockITaskEngineFactory) EXPECT

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

func (*MockITaskEngineFactory) Start

func (m *MockITaskEngineFactory) Start() error

Start mocks base method.

func (*MockITaskEngineFactory) Stop

func (m *MockITaskEngineFactory) Stop() error

Stop mocks base method.

type MockITaskEngineFactoryMockRecorder

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

MockITaskEngineFactoryMockRecorder is the mock recorder for MockITaskEngineFactory.

func (*MockITaskEngineFactoryMockRecorder) Start

Start indicates an expected call of Start.

func (*MockITaskEngineFactoryMockRecorder) Stop

Stop indicates an expected call of Stop.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL