runner

Documentation

Index

• Variables
• func TestRunner()
• type Runner
  • func New(d time.Duration) *Runner
  • func (r *Runner) Add(tasks ...func(int))
  • func (r *Runner) Start() error

Variables

var ErrInterrupt = errors.New("Received interrupt")

var ErrTimeout = errors.New("Received timeout")

Functions

func TestRunner

func TestRunner()

Types

type Runner

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

func New

func New(d time.Duration) *Runner

func (*Runner) Add

func (r *Runner) Add(tasks ...func(int))

func (*Runner) Start

func (r *Runner) Start() error