type Result struct {Args   []stringStdout []byteStderr []byteErrorerror}

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

funcNew¶

func New(inCtxcontext.Context, workersint) *Runner

New creates a new Runner with the given number of workers.If workers is 0, the number of workers will be the number of available CPUs.

func (*Runner)Cancel¶

func (r *Runner) Cancel()

func (*Runner)Enqueue¶

func (r *Runner) Enqueue(task *Task)

func (*Runner)Results¶

func (r *Runner) Results(task *Task) *Result

type Task struct {Args        []string `json:"args"`LimitStderrint      `json:"-"`}

funcNewTask¶

func NewTask(args ...string) *Task

NewTask creates a new Task

funcNewTaskWithLimitedStderr¶

func NewTaskWithLimitedStderr(limitint, args ...string) *Task

NewTaskWithLimitedStderr creates a new Task with a hard-limit on the stderr output

func (*Task)Run¶

func (t *Task) Run(ctxcontext.Context) *Result

Run executes the command and returns the result

func (*Task)String¶

func (t *Task) String()string