taskworker

Documentation

Index

• Constants
• type LHTaskWorker
  • func NewTaskWorker(config *common.LHConfig, taskFunction interface{}, taskDefName string) (*LHTaskWorker, error)
  • func (tw *LHTaskWorker) Close() error
  • func (tw *LHTaskWorker) RegisterTaskDef(ignoreAlreadyExistsError bool) error
  • func (tw *LHTaskWorker) Start() error

Constants

const TOTAL_RETRIES = 5

Types

type LHTaskWorker

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

func NewTaskWorker

func NewTaskWorker(
	config *common.LHConfig,
	taskFunction interface{},
	taskDefName string,
) (*LHTaskWorker, error)

func (*LHTaskWorker) Close

func (tw *LHTaskWorker) Close() error

func (*LHTaskWorker) RegisterTaskDef

func (tw *LHTaskWorker) RegisterTaskDef(ignoreAlreadyExistsError bool) error

func (*LHTaskWorker) Start

func (tw *LHTaskWorker) Start() error