queues

Documentation

Overview

Package queues is a generated GoMock package.

Index

• Constants
• type MockProcessor
  • func NewMockProcessor(ctrl *gomock.Controller) *MockProcessor
  • func (m *MockProcessor) Category() tasks.Category
  • func (m *MockProcessor) EXPECT() *MockProcessorMockRecorder
  • func (m *MockProcessor) FailoverNamespace(namespaceIDs map[string]struct{})
  • func (m *MockProcessor) LockTaskProcessing()
  • func (m *MockProcessor) NotifyNewTasks(clusterName string, tasks []tasks.Task)
  • func (m *MockProcessor) Start()
  • func (m *MockProcessor) Stop()
  • func (m *MockProcessor) UnlockTaskProcessing()
• type MockProcessorFactory
  • func NewMockProcessorFactory(ctrl *gomock.Controller) *MockProcessorFactory
  • func (m *MockProcessorFactory) CreateProcessor(shard shard.Context, engine shard.Engine, cache workflow.Cache) Processor
  • func (m *MockProcessorFactory) EXPECT() *MockProcessorFactoryMockRecorder
• type MockProcessorFactoryMockRecorder
  • func (mr *MockProcessorFactoryMockRecorder) CreateProcessor(shard, engine, cache interface{}) *gomock.Call
• type MockProcessorMockRecorder
  • func (mr *MockProcessorMockRecorder) Category() *gomock.Call
  • func (mr *MockProcessorMockRecorder) FailoverNamespace(namespaceIDs interface{}) *gomock.Call
  • func (mr *MockProcessorMockRecorder) LockTaskProcessing() *gomock.Call
  • func (mr *MockProcessorMockRecorder) NotifyNewTasks(clusterName, tasks interface{}) *gomock.Call
  • func (mr *MockProcessorMockRecorder) Start() *gomock.Call
  • func (mr *MockProcessorMockRecorder) Stop() *gomock.Call
  • func (mr *MockProcessorMockRecorder) UnlockTaskProcessing() *gomock.Call
• type Processor
• type ProcessorFactory

Constants

const (
	ProcessorFactoryFxGroup = "queueProcessorFactory"
)

Types

type MockProcessor

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

MockProcessor is a mock of Processor interface.

func NewMockProcessor

func NewMockProcessor(ctrl *gomock.Controller) *MockProcessor

NewMockProcessor creates a new mock instance.

func (*MockProcessor) Category

func (m *MockProcessor) Category() tasks.Category

Category mocks base method.

func (*MockProcessor) EXPECT

func (m *MockProcessor) EXPECT() *MockProcessorMockRecorder

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

func (*MockProcessor) FailoverNamespace

func (m *MockProcessor) FailoverNamespace(namespaceIDs map[string]struct{})

FailoverNamespace mocks base method.

func (*MockProcessor) LockTaskProcessing

func (m *MockProcessor) LockTaskProcessing()

LockTaskProcessing mocks base method.

func (*MockProcessor) NotifyNewTasks

func (m *MockProcessor) NotifyNewTasks(clusterName string, tasks []tasks.Task)

NotifyNewTasks mocks base method.

func (*MockProcessor) Start

func (m *MockProcessor) Start()

Start mocks base method.

func (*MockProcessor) Stop

func (m *MockProcessor) Stop()

Stop mocks base method.

func (*MockProcessor) UnlockTaskProcessing

func (m *MockProcessor) UnlockTaskProcessing()

UnlockTaskProcessing mocks base method.

type MockProcessorFactory

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

MockProcessorFactory is a mock of ProcessorFactory interface.

func NewMockProcessorFactory

func NewMockProcessorFactory(ctrl *gomock.Controller) *MockProcessorFactory

NewMockProcessorFactory creates a new mock instance.

func (*MockProcessorFactory) CreateProcessor

func (m *MockProcessorFactory) CreateProcessor(shard shard.Context, engine shard.Engine, cache workflow.Cache) Processor

CreateProcessor mocks base method.

func (*MockProcessorFactory) EXPECT

func (m *MockProcessorFactory) EXPECT() *MockProcessorFactoryMockRecorder

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

type MockProcessorFactoryMockRecorder

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

MockProcessorFactoryMockRecorder is the mock recorder for MockProcessorFactory.

func (*MockProcessorFactoryMockRecorder) CreateProcessor

func (mr *MockProcessorFactoryMockRecorder) CreateProcessor(shard, engine, cache interface{}) *gomock.Call

CreateProcessor indicates an expected call of CreateProcessor.

type MockProcessorMockRecorder

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

MockProcessorMockRecorder is the mock recorder for MockProcessor.

func (*MockProcessorMockRecorder) Category

func (mr *MockProcessorMockRecorder) Category() *gomock.Call

Category indicates an expected call of Category.

func (*MockProcessorMockRecorder) FailoverNamespace

func (mr *MockProcessorMockRecorder) FailoverNamespace(namespaceIDs interface{}) *gomock.Call

FailoverNamespace indicates an expected call of FailoverNamespace.

func (*MockProcessorMockRecorder) LockTaskProcessing

func (mr *MockProcessorMockRecorder) LockTaskProcessing() *gomock.Call

LockTaskProcessing indicates an expected call of LockTaskProcessing.

func (*MockProcessorMockRecorder) NotifyNewTasks

func (mr *MockProcessorMockRecorder) NotifyNewTasks(clusterName, tasks interface{}) *gomock.Call

NotifyNewTasks indicates an expected call of NotifyNewTasks.

func (*MockProcessorMockRecorder) Start

func (mr *MockProcessorMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockProcessorMockRecorder) Stop

func (mr *MockProcessorMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

func (*MockProcessorMockRecorder) UnlockTaskProcessing

func (mr *MockProcessorMockRecorder) UnlockTaskProcessing() *gomock.Call

UnlockTaskProcessing indicates an expected call of UnlockTaskProcessing.

type Processor

type Processor interface {
	common.Daemon
	Category() tasks.Category
	NotifyNewTasks(clusterName string, tasks []tasks.Task)
	FailoverNamespace(namespaceIDs map[string]struct{})
	LockTaskProcessing()
	UnlockTaskProcessing()
}

type ProcessorFactory

type ProcessorFactory interface {
	// TODO: remove the cache parameter after workflow cache become a host level component
	// and it can be provided as a parameter when creating a ProcessorFactory instance.
	// Currently, workflow cache is shard level, but we can't get it from shard or engine interface,
	// as that will lead to a cycle dependency issue between shard and workflow package.
	CreateProcessor(shard shard.Context, engine shard.Engine, cache workflow.Cache) Processor
}