queue

Documentation

Index

• type Queue
  • func New() Queue
  • func (q *Queue) Add(t tasks.Task)
  • func (q *Queue) Len() int
  • func (q *Queue) Pop() (tasks.Task, bool)
  • func (q *Queue) SetStatus(taskId, taskSubId, status int)
  • func (q *Queue) Status(taskId int) int
• type Status
  • func (s Status) Get() (status int)
• type StatusMap
  • func NewStatusMap() *StatusMap
  • func (sm *StatusMap) Get(id int) int
  • func (sm *StatusMap) Set(id, subid, status int)

Types

type Queue

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

func New

func New() Queue

func (*Queue) Add

func (q *Queue) Add(t tasks.Task)

func (*Queue) Len

func (q *Queue) Len() int

func (*Queue) Pop

func (q *Queue) Pop() (tasks.Task, bool)

func (*Queue) SetStatus

func (q *Queue) SetStatus(taskId, taskSubId, status int)

func (*Queue) Status

func (q *Queue) Status(taskId int) int

type Status

type Status map[int]int

func (Status) Get

func (s Status) Get() (status int)

type StatusMap

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

func NewStatusMap

func NewStatusMap() *StatusMap

func (*StatusMap) Get

func (sm *StatusMap) Get(id int) int

func (*StatusMap) Set

func (sm *StatusMap) Set(id, subid, status int)