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
	Start(ctx context.Context) error

	// Stop stops the worker and waits for in-progress work to complete
	Stop() error
}

func New

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

type WorkflowRegistry

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