scheduler

Documentation

Index

• Constants
• type BacklogStatus
• type Chore
  • func NewChore(id string, do func(Chore)) Chore
  • func (chore Chore) Errorf(msg string, args ...interface{})
  • func (chore Chore) Infof(msg string, args ...interface{})
  • func (chore Chore) String() string
  • func (chore Chore) UnixExit(rc int)
• type Scheduler
  • func New(workers int, db *db.DB) *Scheduler
  • func (s *Scheduler) Elevate()
  • func (s *Scheduler) Elevator(deadline int)
  • func (s *Scheduler) Run()
  • func (s *Scheduler) Schedule(priority int, chore Chore) error
  • func (s *Scheduler) Status() Status
• type Status
• type Worker
  • func NewWorker(db *db.DB) *Worker
  • func (t Worker) Available() bool
  • func (w *Worker) Execute(chore Chore)
  • func (t *Worker) Release()
  • func (t *Worker) Reserve(task string)
  • func (t Worker) String() string
• type WorkerStatus

Constants

const MaxPriority = 100

Types

type BacklogStatus

type BacklogStatus struct {
	Priority int    `json:"priority"`
	Position int    `json:"position"`
	TaskUUID string `json:"task_uuid"`
}

type Chore

type Chore struct {
	ID         string
	TaskUUID   string
	Encryption string

	Do func(chore Chore)

	Stdout chan string
	Stderr chan string
	Exit   chan int
	Cancel chan bool
}

func NewChore

func NewChore(id string, do func(Chore)) Chore

func (Chore) Errorf

func (chore Chore) Errorf(msg string, args ...interface{})

func (Chore) Infof

func (chore Chore) Infof(msg string, args ...interface{})

func (Chore) String

func (chore Chore) String() string

func (Chore) UnixExit

func (chore Chore) UnixExit(rc int)

type Scheduler

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

func New

func New(workers int, db *db.DB) *Scheduler

func (*Scheduler) Elevate

func (s *Scheduler) Elevate()

func (*Scheduler) Elevator

func (s *Scheduler) Elevator(deadline int)

func (*Scheduler) Run

func (s *Scheduler) Run()

func (*Scheduler) Schedule

func (s *Scheduler) Schedule(priority int, chore Chore) error

func (*Scheduler) Status

func (s *Scheduler) Status() Status

type Status

type Status struct {
	Backlog []BacklogStatus `json:"backlog"`
	Workers []WorkerStatus  `json:"workers"`
}

type Worker

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

func NewWorker

func NewWorker(db *db.DB) *Worker

func (Worker) Available

func (t Worker) Available() bool

func (*Worker) Execute

func (w *Worker) Execute(chore Chore)

func (*Worker) Release

func (t *Worker) Release()

func (*Worker) Reserve

func (t *Worker) Reserve(task string)

func (Worker) String

func (t Worker) String() string

type WorkerStatus

type WorkerStatus struct {
	ID       int    `json:"id"`
	Idle     bool   `json:"idle"`
	TaskUUID string `json:"task_uuid"`
	LastSeen int    `json:"last_seen"`
}