common

Documentation

Overview

Package common is a generated GoMock package.

Index

• 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, arg2 RegistrationDetails)
• type MockPerNSWorkerComponentMockRecorder
  • func (mr *MockPerNSWorkerComponentMockRecorder) DedicatedWorkerOptions(arg0 interface{}) *gomock.Call
  • func (mr *MockPerNSWorkerComponentMockRecorder) Register(arg0, arg1, arg2 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 RegistrationDetails
• type WorkerComponent

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, arg2 RegistrationDetails)

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, arg2 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, RegistrationDetails)
	// DedicatedWorkerOptions returns a PerNSDedicatedWorkerOptions for this worker component.
	DedicatedWorkerOptions(*namespace.Namespace) *PerNSDedicatedWorkerOptions
}

PerNSWorkerComponent represents a per-namespace worker needed for worker role

type RegistrationDetails

type RegistrationDetails struct {
	// TotalWorkers is the number of requested per-namespace workers for this namespace.
	TotalWorkers int
	// Multiplicity is the number of those workers that this particular sdkworker.Worker
	// represents. It may be more than one if the requested number is more than the total
	// number of worker nodes or if consistent hashing decided to place more than one on
	// the same node.
	Multiplicity int
}

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