worker

package

v0.17.0 Latest Latest Go to latest Published: Sep 28, 2023 License: MIT Imports: 10 Imported by: 23

Details

This section is empty.

View Source

var DefaultWorkerOptions = internal.DefaultOptions

This section is empty.

type Options = internal.Options

type RegisterOption workflowinternal.RegisterOption

func WithName(name string) RegisterOption

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

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

func (w *Worker) RegisterActivity(a workflow.Activity, opts ...RegisterOption) error

func (w *Worker) RegisterWorkflow(wf workflow.Workflow, opts ...RegisterOption) error

func (w *Worker) Start(ctx context.Context) error

Start starts the worker.

To stop the worker, cancel the context passed to Start. To wait for completion of the active tasks, call `WaitForCompletion`.

func (w *Worker) WaitForCompletion() error