Documentation
¶
Index ¶
- type 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.