runner

package

v1.1.0 Latest Latest Go to latest Published: Jun 12, 2019 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type TaskRunner struct {
	CurrentDirectory string
	// contains filtered or unexported fields
}

TaskRunner runs tasks

func NewTaskRunner(man *manifest.Manifest, cwd string, writer sdk.Logger) *TaskRunner

NewTaskRunner creates a new task runner instance

func (t *TaskRunner) ActionByName(actionName string) (p sdk.HandlerFactory, err error)

ActionByName returns action handler constructor

func (t *TaskRunner) Run(taskName string, vars sdk.Vars) (err error)

Run executes task by name.

"vars" parameter is optional and allows to override job scope values.

func (t *TaskRunner) RunJob(j sdk.Job, ctx sdk.JobContextAccessor)

RunJob starts job in separate goroutine.

Use ctx.Error channel to track job result and ctx.Cancel() to cancel it.

func (t *TaskRunner) RunTask(taskName string, ctx sdk.JobContextAccessor, scope sdk.ScopeAccessor) error

RunTask starts sub-task by name

Returns an error if task is not defined or returned an error

func (t *TaskRunner) SetContext(ctx context.Context, fn context.CancelFunc)

SetContext sets execution context

func (t *TaskRunner) Stop()

Stop stops task runner

Path	Synopsis
job