worker

Documentation

Index

• Variables
• type ActivityRegistry
• type Options
• type Registry
• type Worker
  • func New(backend backend.Backend, options *Options) Worker
• type WorkflowRegistry

Variables

var DefaultWorkerOptions = internal.DefaultOptions

Types

type ActivityRegistry

type ActivityRegistry interface {
	RegisterActivity(a interface{}) error
}

type Options

type Options = internal.Options

type Registry

type Registry interface {
	WorkflowRegistry
	ActivityRegistry
}

type Worker

type Worker interface {
	Registry

	// Start starts the worker.
	//
	// To stop the worker, cancel the context passed to Start. To wait for completion of the active
	// work items, call `WaitForCompletion`.
	Start(ctx context.Context) error

	// WaitForCompletion
	WaitForCompletion() error
}

func New

func New(backend backend.Backend, options *Options) Worker

type WorkflowRegistry

type WorkflowRegistry interface {
	RegisterWorkflow(w workflow.Workflow) error
}