runner

Documentation

Index

• type TaskRunner
  • func NewTaskRunner(man *manifest.Manifest, cwd string, writer log.Logger) *TaskRunner
  • func (t *TaskRunner) PluginByName(pluginName string) (p plugins.PluginFactory, err error)
  • func (t *TaskRunner) RunJob(j manifest.Job, ctx *job.RunContext)
  • func (t *TaskRunner) RunTask(taskName string) (err error)
  • func (t *TaskRunner) Stop()

Types

type TaskRunner

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

TaskRunner runs tasks

func NewTaskRunner

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

NewTaskRunner creates a new task runner instance

func (*TaskRunner) PluginByName

func (t *TaskRunner) PluginByName(pluginName string) (p plugins.PluginFactory, err error)

PluginByName gets plugin by name

func (*TaskRunner) RunJob

func (t *TaskRunner) RunJob(j manifest.Job, ctx *job.RunContext)

RunJob starts job in separate goroutine.

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

func (*TaskRunner) RunTask

func (t *TaskRunner) RunTask(taskName string) (err error)

RunTask execute task by name

func (*TaskRunner) Stop

func (t *TaskRunner) Stop()

Stop stops task runner