taskctl

Apr 7, 2022

Changes in this version

type Opts

+ func WithKillTimeout(killTimeout time.Duration) Opts

+ type PgidExecutor struct

+ func NewPgidExecutor(stdin io.Reader, stdout, stderr io.Writer, killTimeout time.Duration) (*PgidExecutor, error)

+ func (e *PgidExecutor) Execute(ctx context.Context, job *executor.Job) ([]byte, error)

Oct 5, 2021

Changes in this version

type Opts

+ func WithEnv(env variables.Container) Opts

Aug 19, 2021

Changes in this version

type FileOutputStore

+ func (s *FileOutputStore) Remove(jobID string) error

type OutputStore

+ Remove func(jobID string) error

Aug 4, 2021

Changes in this version

+ const JobIDVariableName

+ type FileOutputStore struct

+ func NewOutputStore(path string) (*FileOutputStore, error)

+ func (s *FileOutputStore) Reader(jobID string, taskName string, outputName string) (io.ReadCloser, error)

+ func (s *FileOutputStore) Writer(jobID string, taskName string, outputName string) (io.WriteCloser, error)

+ type LineWriter struct

+ func (l *LineWriter) Finish()

+ func (l *LineWriter) Lines() [][]byte

+ func (l *LineWriter) Write(p []byte) (n int, err error)

+ type Opts func(*TaskRunner)

+ func WithContexts(contexts map[string]*runner.ExecutionContext) Opts

+ func WithVariables(variables variables.Container) Opts

+ type OutputStore interface

+ Reader func(jobID string, taskName string, outputName string) (io.ReadCloser, error)

+ Writer func(jobID string, taskName string, outputName string) (io.WriteCloser, error)

+ type Runner interface

+ SetOnTaskChange func(func(t *task.Task))

+ type Scheduler struct

+ func NewScheduler(r runner.Runner) *Scheduler

+ func (s *Scheduler) Cancel()

+ func (s *Scheduler) Finish()

+ func (s *Scheduler) OnStageChange(f func(stage *scheduler.Stage))

+ func (s *Scheduler) Schedule(g *scheduler.ExecutionGraph) error

+ type TaskRunner struct

+ OutputFormat string

+ Stderr io.Writer

+ Stdin io.Reader

+ Stdout io.Writer

+ func NewTaskRunner(outputStore OutputStore, opts ...Opts) (*TaskRunner, error)

+ func (r *TaskRunner) Cancel()

+ func (r *TaskRunner) Finish()

+ func (r *TaskRunner) Run(t *task.Task) error

+ func (r *TaskRunner) SetContexts(contexts map[string]*runner.ExecutionContext) *TaskRunner

+ func (r *TaskRunner) SetOnTaskChange(f func(t *task.Task))

+ func (r *TaskRunner) SetVariables(vars variables.Container) *TaskRunner

+ func (r *TaskRunner) WithVariable(key, value string) *TaskRunner