worker

Documentation

Index

• type Worker
  • func NewWorker(ctx context.Context, tc *client.TemporalClient, params models.NewWorkerParams) (Worker, error)

Types

type Worker

type Worker interface {
	Run(ctx context.Context, interruptCh <-chan interface{}, params models.RunWorkerParams) error
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
}

func NewWorker

func NewWorker(ctx context.Context, tc *client.TemporalClient, params models.NewWorkerParams) (Worker, error)