Versions in this module Expand all Collapse all v0 v0.4.0 Nov 27, 2025 Changes in this version type WorkerQueueStatus + Disabled bool v0.3.0 Nov 22, 2025 Changes in this version + func ConfigurePayloadCodecs(codecs ...converter.PayloadCodec) + func DataConverter() converter.DataConverter + func NewEncryptionCodec(key []byte) (converter.PayloadCodec, error) + func RegisterTemporalClient(cli TemporalClient) + func SetAskRoutingMode(mode AskRoutingMode) + func SetDefaultAskTimeout(d time.Duration) + func SetDefaultQueryTimeout(d time.Duration) + type AskRoutingMode int32 + const AskRouteSignal + const AskRouteUpdate + type Registration struct + ActivityQueue string + Kind string + WorkflowQueue string + type Runner struct + func NewRunner(actor actors.Actor) *Runner + func (r *Runner) Activities() map[string]interface{} + func (r *Runner) AddActivityObserver(observer func(string, actors.ActivityCallOptions)) + func (r *Runner) Description() *actors.Description + func (r *Runner) RegisterWorkflow(register func(workflow interface{})) + func (r *Runner) Workflow() interface{} + type TemporalClient interface + DescribeWorkflowExecution func(ctx context.Context, workflowID, runID string) (*workflowservicepb.DescribeWorkflowExecutionResponse, error) + ExecuteWorkflow func(ctx context.Context, options client.StartWorkflowOptions, workflow interface{}, ...) (client.WorkflowRun, error) + QueryWorkflow func(ctx context.Context, workflowID, runID, queryType string, args ...interface{}) (converter.EncodedValue, error) + SignalWithStartWorkflow func(ctx context.Context, workflowID, signalName string, arg interface{}, ...) (client.WorkflowRun, error) + SignalWorkflow func(ctx context.Context, workflowID, runID, signalName string, arg interface{}) error + UpdateWorkflow func(ctx context.Context, options client.UpdateWorkflowOptions) (client.WorkflowUpdateHandle, error) + type WorkerConfig struct + ActivityQueue string + ActivityWorkerOptions *worker.Options + WorkerOptions *worker.Options + WorkflowQueue string + type WorkerHealthSnapshot struct + ActivityQueues []WorkerQueueStatus + WorkflowQueues []WorkerQueueStatus + type WorkerQueueStatus struct + ActorKinds []string + Queue string + Running bool + type WorkerSet struct + func NewWorkerSet(c client.Client, defaults ...WorkerConfig) *WorkerSet + func (s *WorkerSet) HealthSnapshot() WorkerHealthSnapshot + func (s *WorkerSet) Register(actor actors.Actor, cfg WorkerConfig) (Registration, error) + func (s *WorkerSet) StartAll(ctx context.Context) error + func (s *WorkerSet) StopAll()
Go to main page