Versions in this module Expand all Collapse all v1 v1.12.0 Dec 10, 2021 v1.11.2 Nov 25, 2021 Changes in this version + const BlockWorkflow + const FailWorkflow + func EnableVerboseLogging(enable bool) + func InterruptCh() <-chan interface + func PurgeStickyWorkflowCache() + func SetBinaryChecksum(checksum string) + func SetStickyWorkflowCacheSize(cacheSize int) + type ActivityRegistry interface + RegisterActivity func(a interface{}) + RegisterActivityWithOptions func(a interface{}, options activity.RegisterOptions) + type Options = internal.WorkerOptions + type Registry interface + type Worker interface + Run func(interruptCh <-chan interface{}) error + Start func() error + Stop func() + func New(client client.Client, taskQueue string, options Options) Worker + type WorkflowPanicPolicy = internal.WorkflowPanicPolicy + type WorkflowRegistry interface + RegisterWorkflow func(w interface{}) + RegisterWorkflowWithOptions func(w interface{}, options workflow.RegisterOptions) + type WorkflowReplayer interface + RegisterWorkflow func(w interface{}) + RegisterWorkflowWithOptions func(w interface{}, options workflow.RegisterOptions) + ReplayPartialWorkflowHistoryFromJSONFile func(logger log.Logger, jsonfileName string, lastEventID int64) error + ReplayWorkflowExecution func(ctx context.Context, service workflowservice.WorkflowServiceClient, ...) error + ReplayWorkflowHistory func(logger log.Logger, history *historypb.History) error + ReplayWorkflowHistoryFromJSONFile func(logger log.Logger, jsonfileName string) error + func NewWorkflowReplayer() WorkflowReplayer + func NewWorkflowReplayerWithOptions(options WorkflowReplayerOptions) (WorkflowReplayer, error) + type WorkflowReplayerOptions = internal.WorkflowReplayerOptions
Go to main page