Versions in this module Expand all Collapse all v0 v0.1.1 May 27, 2022 Changes in this version + func RunCommand(c Command, taskSet []tasks.Task, wg *sync.WaitGroup) (err error) + type Command struct + Command string + Config Config + Empty bool + Input string + Sequence int64 + Slots int64 + func NewCommand(value string, taskListSet *tasks.TaskListSet, config Config) Command + func (c *Command) Copy() (newCommand Command) + func (c *Command) Execute() (err error) + func (c *Command) GetSequence() int64 + func (c *Command) Prepare(tasks []tasks.Task) (err error) + func (c *Command) Print(file *os.File, str string) + func (c *Command) SequenceIncr() + func (c *Command) SequenceReset() + func (c *Command) SetConcurrency(concurrency int64) + func (c Command) GetSlotNumber() int64 + type Config struct + Awk *awk.Command + Concurrency int64 + DryRun bool + ExitOnError bool + KeepOrder bool + PrintEmpty bool + Slots int64 + StdIn bool
Go to main page