type Runner …
const maxInFlight …
func (runner *Runner) initialize() { … }
var modConcurrencyError …
func (runner *Runner) Run(ctx context.Context, inv Invocation) (*bytes.Buffer, error) { … }
func (runner *Runner) RunPiped(ctx context.Context, inv Invocation, stdout, stderr io.Writer) error { … }
func (runner *Runner) RunRaw(ctx context.Context, inv Invocation) (*bytes.Buffer, *bytes.Buffer, error, error) { … }
func (runner *Runner) runConcurrent(ctx context.Context, inv Invocation) (*bytes.Buffer, *bytes.Buffer, error, error) { … }
func (runner *Runner) runPiped(ctx context.Context, inv Invocation, stdout, stderr io.Writer) (error, error) { … }
type Invocation …
func (i *Invocation) runWithFriendlyError(ctx context.Context, stdout, stderr io.Writer) (friendlyError error, rawError error) { … }
func (i *Invocation) run(ctx context.Context, stdout, stderr io.Writer) error { … }
func runCmdContext(ctx context.Context, cmd *exec.Cmd) error { … }
func cmdDebugStr(cmd *exec.Cmd) string { … }