task

Documentation

Index

• type TaskWorker
  • func NewWorker(config config.Config, ...) *TaskWorker
  • func (worker *TaskWorker) Process(taskInput *message.TaskInput) (*message.TaskOutput, error)

Types

type TaskWorker

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

func NewWorker

func NewWorker(
	config config.Config,
	taskExecutor,
	parallelExecutor,
	waitExecutor,
	passExecutor,
	choiceExecutor executor.Executor,
	lock lock.Locker,
	logger zerolog.Logger,
	lockTimeout time.Duration,
	tracer *opentracer.ServiceTracer,
) *TaskWorker

func (*TaskWorker) Process

func (worker *TaskWorker) Process(taskInput *message.TaskInput) (*message.TaskOutput, error)