worker

Aug 8, 2024

Changes in this version

+ var ErrNoExec = errors.New("no execution")

+ func Run(configPath string, taskPaths []string) error

+ type APIExecutionSource struct

+ func (a *APIExecutionSource) Next() (Execution, error)

+ func (a *APIExecutionSource) Report(result Result) error

+ type Execution client.GetWorkV1Response

+ type ExecutionSource interface

+ Next func() (Execution, error)

+ Report func(Result) error

+ type Result struct

+ Execution Execution

+ RunError error

+ TaskResults []command.RunResult

+ type Worker struct

+ Exec ExecutionSource

+ ParallelExecutions int

+ func NewWorker(configPath string, taskPaths []string) (*Worker, error)

+ func (w *Worker) Start()

+ func (w *Worker) Stop() chan struct{}