taskengine

Mar 8, 2019

Changes in this version

+ func Run(ctx *context.Context, executor TaskRunner, selector TaskSelector, ...) (bool, error)

+ type TaskRunner interface

+ Run func(*taskapi.Task) error

+ func NewTaskRunner(ctx *context.Context) TaskRunner

+ type TaskRunnerImpl struct

+ func (r *TaskRunnerImpl) Run(task *taskapi.Task) (err error)

+ type TaskSelector interface

+ ShouldRun func(*taskapi.Task) (bool, error)

+ type TaskSelectorImpl struct

+ func NewTaskSelector() *TaskSelectorImpl

+ func (s *TaskSelectorImpl) ShouldRun(task *taskapi.Task) (bool, error)