scheduler

Documentation

Index

• Variables
• type Scheduler
  • func New(targets types.Targets, tasks types.Tasks) (s *Scheduler, ready map[string][]string, err error)
  • func (s *Scheduler) Next(completed string) (ready map[string][]string, err error)

Variables

var ErrNoPendingTasks = errors.New("all tasks have been scheduled")

Types

type Scheduler

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

A Scheduler determines which tasks are ready for execution based on task dependencies and target capacity.

func New

func New(targets types.Targets, tasks types.Tasks) (s *Scheduler, ready map[string][]string, err error)

New initializes a new Scheduler, and returns a set of tasks ready for immediate execution

func (*Scheduler) Next

func (s *Scheduler) Next(completed string) (ready map[string][]string, err error)

Next returns a set of tasks ready for execution given a completed task