Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ErrorListener ¶
type ErrorListener interface {
HandleError()
}
type RestartableTask ¶
type TaskManager ¶
type TaskManager struct {
// contains filtered or unexported fields
}
func NewTaskManager ¶
func NewTaskManager(parentContext context.Context, maxWorkerCount int32) *TaskManager
func (*TaskManager) GoWork ¶
func (m *TaskManager) GoWork(newTask Task)
func (*TaskManager) Status ¶
func (m *TaskManager) Status() map[int32]*WorkerInfo
func (*TaskManager) Stop ¶
func (m *TaskManager) Stop()
func (*TaskManager) TaskWithProgressStatus ¶
func (m *TaskManager) TaskWithProgressStatus() map[string]TaskWithProgress
type TaskWithProgress ¶
type WorkerInfo ¶
Click to show internal directories.
Click to hide internal directories.