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{}) error
  • func (pq JobPriorityQueue) PushItem(i qItem.Item, piority int)
  • func (pq JobPriorityQueue) Remove(hash string)

Types

type JobPriorityQueue

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

JobPriorityQueue priority queue of jobs

func NewJobPriorityQueue

func NewJobPriorityQueue() *JobPriorityQueue

NewJobPriorityQueue initializes a job priority queue

func (JobPriorityQueue) GetPQ

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

GetPQ returns priority queue

func (JobPriorityQueue) Len

func (pq JobPriorityQueue) Len() int

Len returns the size of the priority queue

func (JobPriorityQueue) Pop

func (pq JobPriorityQueue) Pop() qItem.Item

Pop returns next item in the queue

func (JobPriorityQueue) Push

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

Push adds item config to priority queue

func (JobPriorityQueue) PushItem

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

PushItem adds item to priority queue

func (JobPriorityQueue) Remove

func (pq JobPriorityQueue) Remove(hash string)

Remove removes item from the priority queue