task

type Options struct {
	Retry *Retry `json:"retry,omitempty"`
}

type Retry struct {
	MaxRetries   int           `json:"max_retries"`
	WaitDuration time.Duration `json:"wait_duration"`
	Factor       float32       `json:"factor"`
}

type Task interface{}

type TaskContext interface {
	ExecuteTask(task Task, input ...interface{}) *TaskResult
}

type TaskInfo struct {
	Task    Task     `json:"-"`
	Options *Options `json:"options,omitempty"`
}

type TaskResult struct {
	Result []interface{}
	Error  error
}

type Tasks struct {
	Tasks map[string]*TaskInfo
}