runner

package

v1.0.10 Latest Latest Go to latest Published: Sep 24, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

func IsErrInterrupt(err error) bool

func IsErrTimeout(err error) bool

type ErrType int

const (
	ErrTypeNormal ErrType = iota
	ErrTypeTimeout
	ErrTypeInterrupt
)

func (errType ErrType) String() string

type Error struct {
	Type ErrType
	Name string
}

func (e *Error) Error() string

type Job struct {
	Name string
	Task Task
}

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

func NewRunner(ctx context.Context, name string, numWorkers int) *Runner

func (r *Runner) Add(task Task, desc ...string)

func (r *Runner) Commit() (err error)

type Task func(ctx context.Context) error