scheduler

Documentation

Index

• type Action
• type Priority
• type Processor
• type Schd
  • func (s *Schd) AddProcessor(name string) error
  • func (s *Schd) AddTask(task Task, toHead bool)
  • func (s *Schd) ClearTaskQueue(priority Priority)
  • func (s *Schd) DelProcessor(name string) (string, error)
  • func (s *Schd) DeleteTask(key string, priority Priority) bool
  • func (s *Schd) Init()
  • func (s *Schd) Reset()
  • func (s *Schd) TaskCount() int
  • func (s *Schd) TaskDone(task Task, action Action)
• type Task

Types

type Action

type Action int

const (
	TaskActionDone Action = iota
	TaskActionWait
	TaskActionRetry
	TaskActionRequeue
	TaskActionRequeueWait
)

type Priority

type Priority int

const PriorityHigh Priority = 0

const PriorityLow Priority = 1

type Processor

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

type Schd

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

func (*Schd) AddProcessor

func (s *Schd) AddProcessor(name string) error

func (*Schd) AddTask

func (s *Schd) AddTask(task Task, toHead bool)

func (*Schd) ClearTaskQueue

func (s *Schd) ClearTaskQueue(priority Priority)

func (*Schd) DelProcessor

func (s *Schd) DelProcessor(name string) (string, error)

func (*Schd) DeleteTask

func (s *Schd) DeleteTask(key string, priority Priority) bool

func (*Schd) Init

func (s *Schd) Init()

func (*Schd) Reset

func (s *Schd) Reset()

func (*Schd) TaskCount

func (s *Schd) TaskCount() int

func (*Schd) TaskDone

func (s *Schd) TaskDone(task Task, action Action)

type Task

type Task interface {
	Key() string
	Priority() Priority
	Handler(proc string) Action
	StartTimer()
	CancelTimer()
	Print(msg string)
}