sequencetaskhelper

Documentation

Index

• Constants
• type SequenceTask
  • func NewSequenceTask(stopWhileMeetErr bool, seqNum int, taskFunc func(map[string]interface{}) error, ...) (sequenceTask SequenceTask)
  • func (a *SequenceTask) AddTask(data map[string]interface{})
  • func (a *SequenceTask) DeleteTask(filter func(map[string]interface{}) bool)
  • func (a *SequenceTask) End()
  • func (a *SequenceTask) ReloadTask(data []map[string]interface{})
  • func (a *SequenceTask) Start()

Constants

const END_SEQUENCE = "END_SEQUENCE"

const START_SEQUENCE = "START_SEQUENCE"

Types

type SequenceTask

type SequenceTask struct {
	StopWhileMeetErr   bool
	Ch                 chan map[string]interface{}
	SeqNum             int
	SeqNumMutex        sync.RWMutex
	CurrentRunningTask int
	ChStatus           string
	TaskFunc           func(map[string]interface{}) error
	RecordSuccessFunc  func(map[string]interface{})
	RecordFailFunc     func(map[string]interface{})
	DeleteTaskCh       chan func(map[string]interface{}) bool // this is insecure when task is executing, so need to stop execute when end current, then delete
}

func NewSequenceTask

func NewSequenceTask(
	stopWhileMeetErr bool,
	seqNum int,
	taskFunc func(map[string]interface{}) error,
	recordSuccessFunc func(map[string]interface{}),
	recordFailFunc func(map[string]interface{}),
) (sequenceTask SequenceTask)

func (*SequenceTask) AddTask

func (a *SequenceTask) AddTask(data map[string]interface{})

func (*SequenceTask) DeleteTask

func (a *SequenceTask) DeleteTask(filter func(map[string]interface{}) bool)

func (*SequenceTask) End

func (a *SequenceTask) End()

func (*SequenceTask) ReloadTask

func (a *SequenceTask) ReloadTask(data []map[string]interface{})

func (*SequenceTask) Start

func (a *SequenceTask) Start()