parallel

Documentation

Index

• func Run(ctx context.Context, exitWait time.Duration, ...) error
• type Prob
• type Runner
  • func (p *Runner) ActualStatus()
  • func (p *Runner) ExpectStatus()
  • func (p *Runner) Fork(parallel *Runner)
  • func (p *Runner) ForkGroup(coupled bool, runner ...func(ctx context.Context) error)
  • func (p *Runner) Stop()

Functions

func Run

func Run(ctx context.Context, exitWait time.Duration, runner ...func(ctx context.Context) error) error

Types

type Prob

type Prob struct {
}

type Runner

type Runner struct {
	// contains filtered or unexported fields
}

func (*Runner) ActualStatus

func (p *Runner) ActualStatus()

func (*Runner) ExpectStatus

func (p *Runner) ExpectStatus()

func (*Runner) Fork

func (p *Runner) Fork(parallel *Runner)

func (*Runner) ForkGroup

func (p *Runner) ForkGroup(coupled bool, runner ...func(ctx context.Context) error)

func (*Runner) Stop

func (p *Runner) Stop()