repeatingtask

May 18, 2020

Changes in this version

+ const InfiniteFailures

+ type Pool struct

+ func NewPool(ctx context.Context, maxTasks int, numWorkers int) (*Pool, error)

+ func (p *Pool) SubmitTask(task *Task) error

+ func (p *Pool) SubmitTaskAndWait(task *Task) TaskErrors

+ type Task struct

+ Cookie interface{}

+ ErrorsChan chan *TaskError

+ Handler func(interface{}, int) error

+ MaxNumErrors int

+ MaxParallel int

+ NumReptitions int

+ OnCompleteChan chan struct{}

+ Timeout time.Duration

+ func (t *Task) Wait() TaskErrors

+ type TaskError struct

+ Error error

+ Repetition int

+ type TaskErrors struct

+ func (te *TaskErrors) Error() error

+ func (te *TaskErrors) String() string

+ type TaskGroup struct

+ func NewTaskGroup() (*TaskGroup, error)

+ func (t *TaskGroup) AddTask(task *Task) error

+ func (t *TaskGroup) Wait() TaskGroupErrors

+ type TaskGroupErrors struct

+ func (tge *TaskGroupErrors) Error() error

+ func (tge *TaskGroupErrors) Errors() []error