common

Documentation

Overview

Package common is a generated GoMock package.

Index

• Constants
• type DedicatedWorkerOptions
• type MockPerNSWorkerComponent
  • func NewMockPerNSWorkerComponent(ctrl *gomock.Controller) *MockPerNSWorkerComponent
  • func (m *MockPerNSWorkerComponent) DedicatedWorkerOptions(arg0 *namespace.Namespace) *PerNSDedicatedWorkerOptions
  • func (m *MockPerNSWorkerComponent) EXPECT() *MockPerNSWorkerComponentMockRecorder
  • func (m *MockPerNSWorkerComponent) Register(arg0 worker.Worker, arg1 *namespace.Namespace)
• type MockPerNSWorkerComponentMockRecorder
  • func (mr *MockPerNSWorkerComponentMockRecorder) DedicatedWorkerOptions(arg0 interface{}) *gomock.Call
  • func (mr *MockPerNSWorkerComponentMockRecorder) Register(arg0, arg1 interface{}) *gomock.Call
• type MockWorkerComponent
  • func NewMockWorkerComponent(ctrl *gomock.Controller) *MockWorkerComponent
  • func (m *MockWorkerComponent) DedicatedWorkerOptions() *DedicatedWorkerOptions
  • func (m *MockWorkerComponent) EXPECT() *MockWorkerComponentMockRecorder
  • func (m *MockWorkerComponent) Register(arg0 worker.Worker)
• type MockWorkerComponentMockRecorder
  • func (mr *MockWorkerComponentMockRecorder) DedicatedWorkerOptions() *gomock.Call
  • func (mr *MockWorkerComponentMockRecorder) Register(arg0 interface{}) *gomock.Call
• type PerNSDedicatedWorkerOptions
• type PerNSWorkerComponent
• type WorkerComponent

Constants

const (
	// All per-ns workers share one task queue
	PerNSWorkerTaskQueue = "temporal-sys-per-ns-tq"
)

Types

type DedicatedWorkerOptions

type DedicatedWorkerOptions struct {
	// TaskQueue is optional
	TaskQueue string
	// How many worker nodes should run a worker per namespace
	NumWorkers int
	// Other worker options
	Options sdkworker.Options
}

type MockPerNSWorkerComponent

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

MockPerNSWorkerComponent is a mock of PerNSWorkerComponent interface.

func NewMockPerNSWorkerComponent

func NewMockPerNSWorkerComponent(ctrl *gomock.Controller) *MockPerNSWorkerComponent

NewMockPerNSWorkerComponent creates a new mock instance.

func (*MockPerNSWorkerComponent) DedicatedWorkerOptions

func (m *MockPerNSWorkerComponent) DedicatedWorkerOptions(arg0 *namespace.Namespace) *PerNSDedicatedWorkerOptions

DedicatedWorkerOptions mocks base method.

func (*MockPerNSWorkerComponent) EXPECT

func (m *MockPerNSWorkerComponent) EXPECT() *MockPerNSWorkerComponentMockRecorder

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

func (*MockPerNSWorkerComponent) Register

func (m *MockPerNSWorkerComponent) Register(arg0 worker.Worker, arg1 *namespace.Namespace)

Register mocks base method.

type MockPerNSWorkerComponentMockRecorder

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

MockPerNSWorkerComponentMockRecorder is the mock recorder for MockPerNSWorkerComponent.

func (*MockPerNSWorkerComponentMockRecorder) DedicatedWorkerOptions

func (mr *MockPerNSWorkerComponentMockRecorder) DedicatedWorkerOptions(arg0 interface{}) *gomock.Call

DedicatedWorkerOptions indicates an expected call of DedicatedWorkerOptions.

func (*MockPerNSWorkerComponentMockRecorder) Register

func (mr *MockPerNSWorkerComponentMockRecorder) Register(arg0, arg1 interface{}) *gomock.Call

Register indicates an expected call of Register.

type MockWorkerComponent

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

MockWorkerComponent is a mock of WorkerComponent interface.

func NewMockWorkerComponent

func NewMockWorkerComponent(ctrl *gomock.Controller) *MockWorkerComponent

NewMockWorkerComponent creates a new mock instance.

func (*MockWorkerComponent) DedicatedWorkerOptions

func (m *MockWorkerComponent) DedicatedWorkerOptions() *DedicatedWorkerOptions

DedicatedWorkerOptions mocks base method.

func (*MockWorkerComponent) EXPECT

func (m *MockWorkerComponent) EXPECT() *MockWorkerComponentMockRecorder

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

func (*MockWorkerComponent) Register

func (m *MockWorkerComponent) Register(arg0 worker.Worker)

Register mocks base method.

type MockWorkerComponentMockRecorder

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

MockWorkerComponentMockRecorder is the mock recorder for MockWorkerComponent.

func (*MockWorkerComponentMockRecorder) DedicatedWorkerOptions

func (mr *MockWorkerComponentMockRecorder) DedicatedWorkerOptions() *gomock.Call

DedicatedWorkerOptions indicates an expected call of DedicatedWorkerOptions.

func (*MockWorkerComponentMockRecorder) Register

func (mr *MockWorkerComponentMockRecorder) Register(arg0 interface{}) *gomock.Call

Register indicates an expected call of Register.

type PerNSDedicatedWorkerOptions

type PerNSDedicatedWorkerOptions struct {
	// Set this to false to disable this worker for this namespace
	Enabled bool
}

type PerNSWorkerComponent

type PerNSWorkerComponent interface {
	// Register registers Workflow and Activity types provided by this worker component.
	// The namespace that this worker is running in is also provided.
	Register(sdkworker.Worker, *namespace.Namespace)
	// DedicatedWorkerOptions returns a PerNSDedicatedWorkerOptions for this worker component.
	DedicatedWorkerOptions(*namespace.Namespace) *PerNSDedicatedWorkerOptions
}

PerNSWorkerComponent represents a per-namespace worker needed for worker role

type WorkerComponent

type WorkerComponent interface {
	// Register registers Workflow and Activity types provided by this worker component.
	Register(sdkworker.Worker)
	// DedicatedWorkerOptions returns a DedicatedWorkerOptions for this worker component.
	// Return nil to use default worker instance.
	DedicatedWorkerOptions() *DedicatedWorkerOptions
}

WorkerComponent represents a type of work needed for worker role