Versions in this module Expand all Collapse all v0 v0.1.0 Jan 18, 2022 Changes in this version + type Context struct + FinalData interface{} + InitData interface{} + IntermediateData interface{} + Status api.TaskStatus + type Decider struct + func NewDecider(pool *WorkerPool, taskQ <-chan *Task) *Decider + func (d *Decider) Start() + type Job interface + GetResult func() map[string]interface{} + Id func() string + type JobRunner struct + func NewJobRunner(taskQ chan<- *Task, store JobStore) *JobRunner + func (j *JobRunner) ShutDown() + func (j *JobRunner) Start() + func (j *JobRunner) Submit(job Job) + func (j JobRunner) InterruptCurrentJob() + type JobStore interface + Load func(jobId string) (job Job, exist bool) + Store func(job Job) + func NewSimpleStore() JobStore + type Spliterator interface + TryAdvance func(func(task *Task)) (finished bool) + type Task struct + Ctx *Context + FuncId string + Id string + JobId string + UpdateHandler func(*Task) + type WorkerPool struct + func NewWorkerPool() *WorkerPool + func (w *WorkerPool) Add(id string, ch chan *api.Msg) + func (w *WorkerPool) InterruptJobTasks(jobId string) + func (w *WorkerPool) Remove(id string) + func (w *WorkerPool) UpdateStatus(id string, payload *api.StatusPayload) error