common

Documentation

Overview

Package common is a generated GoMock package.

Index

• Constants
• func AnnotateWorkerComponentProvider[T any](f func(t T) WorkerComponent) fx.Option
• type ActivityWorkerLimitsConfig
  • func NewActivityWorkerConcurrencyConfig(dc *dynamicconfig.Collection, key dynamicconfig.Key, defaults map[string]any) ActivityWorkerLimitsConfig
• 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.Registry, 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) DedicatedActivityWorkerOptions() *DedicatedWorkerOptions
  • func (m *MockWorkerComponent) DedicatedWorkflowWorkerOptions() *DedicatedWorkerOptions
  • func (m *MockWorkerComponent) EXPECT() *MockWorkerComponentMockRecorder
  • func (m *MockWorkerComponent) RegisterActivities(registry worker.Registry)
  • func (m *MockWorkerComponent) RegisterWorkflow(registry worker.Registry)
• type MockWorkerComponentMockRecorder
  • func (mr *MockWorkerComponentMockRecorder) DedicatedActivityWorkerOptions() *gomock.Call
  • func (mr *MockWorkerComponentMockRecorder) DedicatedWorkflowWorkerOptions() *gomock.Call
  • func (mr *MockWorkerComponentMockRecorder) RegisterActivities(registry interface{}) *gomock.Call
  • func (mr *MockWorkerComponentMockRecorder) RegisterWorkflow(registry interface{}) *gomock.Call
• type PerNSDedicatedWorkerOptions
• type PerNSWorkerComponent
• type RegistrationDetails
• type WorkerComponent

Constants

const WorkerComponentTag = `group:"workerComponent"`

WorkerComponentTag is the fx group tag for worker components. This is used to allow those who use Temporal as a library to dynamically register their own system workers. Use this to annotate a worker component consumer. Use the AnnotateWorkerComponentProvider function to annotate a worker component provider.

Functions

func AnnotateWorkerComponentProvider

func AnnotateWorkerComponentProvider[T any](f func(t T) WorkerComponent) fx.Option

AnnotateWorkerComponentProvider converts a WorkerComponent factory function into an fx provider which will add the WorkerComponentTag to the result.

Types

type ActivityWorkerLimitsConfig

type ActivityWorkerLimitsConfig struct {
	// copy of relevant remote activity controls from sdkworker.Options
	MaxConcurrentActivityExecutionSize int
	TaskQueueActivitiesPerSecond       float64
	WorkerActivitiesPerSecond          float64
	MaxConcurrentActivityTaskPollers   int
}

func NewActivityWorkerConcurrencyConfig

func NewActivityWorkerConcurrencyConfig(
	dc *dynamicconfig.Collection,
	key dynamicconfig.Key,
	defaults map[string]any,
) ActivityWorkerLimitsConfig

NewActivityWorkerConcurrencyConfig constructs an ActivityWorkerLimitsConfig from the map of values identified by key in the dynamic collection. Any errors are ignored and 0 values will be returned instead.

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.Registry, 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) DedicatedActivityWorkerOptions

func (m *MockWorkerComponent) DedicatedActivityWorkerOptions() *DedicatedWorkerOptions

DedicatedActivityWorkerOptions mocks base method.

func (*MockWorkerComponent) DedicatedWorkflowWorkerOptions

func (m *MockWorkerComponent) DedicatedWorkflowWorkerOptions() *DedicatedWorkerOptions

DedicatedWorkflowWorkerOptions 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) RegisterActivities

func (m *MockWorkerComponent) RegisterActivities(registry worker.Registry)

RegisterActivities mocks base method.

func (*MockWorkerComponent) RegisterWorkflow

func (m *MockWorkerComponent) RegisterWorkflow(registry worker.Registry)

RegisterWorkflow mocks base method.

type MockWorkerComponentMockRecorder

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

MockWorkerComponentMockRecorder is the mock recorder for MockWorkerComponent.

func (*MockWorkerComponentMockRecorder) DedicatedActivityWorkerOptions

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

DedicatedActivityWorkerOptions indicates an expected call of DedicatedActivityWorkerOptions.

func (*MockWorkerComponentMockRecorder) DedicatedWorkflowWorkerOptions

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

DedicatedWorkflowWorkerOptions indicates an expected call of DedicatedWorkflowWorkerOptions.

func (*MockWorkerComponentMockRecorder) RegisterActivities

func (mr *MockWorkerComponentMockRecorder) RegisterActivities(registry interface{}) *gomock.Call

RegisterActivities indicates an expected call of RegisterActivities.

func (*MockWorkerComponentMockRecorder) RegisterWorkflow

func (mr *MockWorkerComponentMockRecorder) RegisterWorkflow(registry interface{}) *gomock.Call

RegisterWorkflow indicates an expected call of RegisterWorkflow.

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.Registry, *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 {
	// RegisterWorkflow registers Workflow types provided by this worker component.
	// Local Activities should also be registered here because they are executed on the workflow worker.
	RegisterWorkflow(registry sdkworker.Registry)
	// DedicatedWorkflowWorkerOptions returns a DedicatedWorkerOptions for this worker component.
	// Return nil to use default worker instance.
	DedicatedWorkflowWorkerOptions() *DedicatedWorkerOptions
	// RegisterActivities registers remote Activity types provided by this worker component.
	// Local Activities should be registered in RegisterWorkflow
	RegisterActivities(registry sdkworker.Registry)
	// DedicatedActivityWorkerOptions returns a DedicatedWorkerOptions for this worker component.
	// Return nil to use default worker instance.
	DedicatedActivityWorkerOptions() *DedicatedWorkerOptions
}

WorkerComponent represents a type of work needed for worker role