executor

type Manager interface {
	AddTask(task task.Task) error
	RemoveTask(task task.Task)
	// Start starts the Manager sync loops.
	Start()
	Stop()
	TaskManager() *task.TaskManager
	GetWorker(taskID string, eventID string) (Worker, bool)
	WorkerCount() int
}

type Worker interface {
	Start()
	Cancel() error
	RollBack() error
	Status() string
}