Documentation ¶ Index ¶ type Executor func NewParallel(concurrencyLimit int64, continueOnError bool) Executor type Parallel func (e *Parallel) Execute() error func (e *Parallel) IsFinished() bool func (e *Parallel) Submit(t Task) type Task Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Executor ¶ type Executor interface { Submit(t Task) Execute() error IsFinished() bool } func NewParallel ¶ func NewParallel(concurrencyLimit int64, continueOnError bool) Executor type Parallel ¶ type Parallel struct { // contains filtered or unexported fields } func (*Parallel) Execute ¶ func (e *Parallel) Execute() error func (*Parallel) IsFinished ¶ func (e *Parallel) IsFinished() bool func (*Parallel) Submit ¶ func (e *Parallel) Submit(t Task) type Task ¶ type Task interface { Run() error GetName() string } Source Files ¶ View all Source files executor.go parallel_executor.go Click to show internal directories. Click to hide internal directories.