queue

Documentation

Index

• type JobPriorityQueue
  • func NewJobPriorityQueue() *JobPriorityQueue
  • func (pq JobPriorityQueue) GetPQ() *lane.PQueue
  • func (pq JobPriorityQueue) Len() int
  • func (pq JobPriorityQueue) Pop() qItem.Item
  • func (pq JobPriorityQueue) Push(j job.Job, exec *job.Exec, results chan<- qItem.Item, cancel chan struct{})
  • func (pq JobPriorityQueue) PushItem(i qItem.Item, piority int)
  • func (pq JobPriorityQueue) Remove(hash []byte)

Types

type JobPriorityQueue

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

func NewJobPriorityQueue

func NewJobPriorityQueue() *JobPriorityQueue

func (JobPriorityQueue) GetPQ

func (pq JobPriorityQueue) GetPQ() *lane.PQueue

func (JobPriorityQueue) Len

func (pq JobPriorityQueue) Len() int

func (JobPriorityQueue) Pop

func (pq JobPriorityQueue) Pop() qItem.Item

func (JobPriorityQueue) Push

func (pq JobPriorityQueue) Push(j job.Job, exec *job.Exec, results chan<- qItem.Item, cancel chan struct{})

func (JobPriorityQueue) PushItem

func (pq JobPriorityQueue) PushItem(i qItem.Item, piority int)

func (JobPriorityQueue) Remove

func (pq JobPriorityQueue) Remove(hash []byte)