Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ParallelRunner ¶
type ParallelRunner struct {
// contains filtered or unexported fields
}
func NewParallelRunner ¶
func NewParallelRunner(ctx context.Context, maxRun int64) *ParallelRunner
func (*ParallelRunner) DoneChan ¶
func (p *ParallelRunner) DoneChan() <-chan struct{}
func (*ParallelRunner) Err ¶
func (p *ParallelRunner) Err() error
func (*ParallelRunner) Read ¶
func (p *ParallelRunner) Read() chan interface{}
func (*ParallelRunner) Run ¶
func (p *ParallelRunner) Run(runnable func() (interface{}, error))
func (*ParallelRunner) Stop ¶
func (p *ParallelRunner) Stop(err error)
func (*ParallelRunner) SubRunner ¶
func (p *ParallelRunner) SubRunner() *ParallelRunner
Source Files
Click to show internal directories.
Click to hide internal directories.