taskengine

Documentation

Index

• func Run(ctx *context.Context, executor TaskRunner, selector TaskSelector, ...) (bool, error)
• type TaskRunner
  • func NewTaskRunner(ctx *context.Context) TaskRunner
• type TaskRunnerImpl
  • func (r *TaskRunnerImpl) Run(task *taskapi.Task) (err error)
• type TaskSelector
• type TaskSelectorImpl
  • func NewTaskSelector() *TaskSelectorImpl
  • func (s *TaskSelectorImpl) ShouldRun(task *taskapi.Task) (bool, error)

Functions

func Run

func Run(ctx *context.Context, executor TaskRunner, selector TaskSelector, taskList []*taskapi.Task) (bool, error)

Run accepts a list of tasks and check for their requirements and runs them if their conditions are met

Types

type TaskRunner

type TaskRunner interface {
	Run(*taskapi.Task) error
}

func NewTaskRunner

func NewTaskRunner(ctx *context.Context) TaskRunner

type TaskRunnerImpl

type TaskRunnerImpl struct {
	// contains filtered or unexported fields
}

func (*TaskRunnerImpl) Run

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

type TaskSelector

type TaskSelector interface {
	ShouldRun(*taskapi.Task) (bool, error)
}

type TaskSelectorImpl

type TaskSelectorImpl struct {
	// contains filtered or unexported fields
}

func NewTaskSelector

func NewTaskSelector() *TaskSelectorImpl

func (*TaskSelectorImpl) ShouldRun

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