Versions in this module Expand all Collapse all v0 v0.0.2 Jan 14, 2021 v0.0.1 Aug 21, 2020 Changes in this version + type ErrorListener interface + HandleError func() + type RestartableTask interface + Restart func() + type Task interface + Execute func(context.Context) error + Name func() string + type TaskManager struct + func NewTaskManager(parentContext context.Context, maxWorkerCount int32) *TaskManager + func (m *TaskManager) GoWork(newTask Task) + func (m *TaskManager) Status() map[int32]*WorkerInfo + func (m *TaskManager) Stop() + func (m *TaskManager) TaskWithProgressStatus() map[string]TaskWithProgress + type TaskWithProgress interface + Description func() string + Name func() string + Pause func() + Progress func() (float64, error) + type WorkerInfo struct + Status string + TaskName string