scheduler

Documentation

Index

• func Run(ctx context.Context, env *model.Environment, numWorkers int, p plan.Plan, ...) (int, error)
• type Error
  • func (e *Error) Error() string
• type Work

Functions

func Run

func Run(ctx context.Context, env *model.Environment, numWorkers int, p plan.Plan, pred func(work Work) (bool, error), f func(work Work) error) (int, error)

Types

type Error

type Error struct {
	Work Work
	Err  error
}

func (*Error) Error

func (e *Error) Error() string

type Work

type Work struct {
	I      int
	Target *model.Target
	Cmd    string
}