process

Feb 5, 2017

Changes in this version

+ var ErrCancelled = fmt.Errorf("cancelled")

+ var ErrTimeout = fmt.Errorf("time out")

+ var Log *logging.Logger

+ var OutputChunkSize = 16384

+ var TmpOutputDataBuffer = 1048576

+ var Verbose bool

+ func Run(opts *Options, cancel chan struct{}, chCmdStr chan string) (chan *Command, chan string, chan int)

+ func Run4Output(opts *Options, cancel chan struct{}, chCmdStr chan string) (chan string, chan string, chan int)

+ type Command struct

+ Cancel chan struct{}

+ Ch chan string

+ Cmd string

+ Duration time.Duration

+ Err error

+ ID uint64

+ Timeout time.Duration

+ func NewCommand(id uint64, cmdStr string, cancel chan struct{}, timeout time.Duration) *Command

+ func (c *Command) Cleanup() error

+ func (c *Command) ExitCode() int

+ func (c *Command) Run() error

+ func (c *Command) String() string

+ type Options struct

+ DryRun bool

+ Jobs int

+ KeepOrder bool

+ RecordSuccessfulCmd bool

+ Retries int

+ RetryInterval time.Duration

+ StopOnErr bool

+ Timeout time.Duration

+ Verbose bool