scheduler_util

Documentation

Index

• Constants
• func CheckNodeConditionPredicate(node *v1.Node) (bool, []string, error)
• func ValidateIsNodeReady(node *v1.Node) bool
• type PriorityQueue
  • func NewPriorityQueue(lessFn common_info.LessFn, maxQueueSize int) *PriorityQueue
  • func (q *PriorityQueue) Empty() bool
  • func (q *PriorityQueue) Fix(index int)
  • func (q *PriorityQueue) Len() int
  • func (q *PriorityQueue) Peek() interface{}
  • func (q *PriorityQueue) Pop() interface{}
  • func (q *PriorityQueue) Push(it interface{})

Constants

const QueueCapacityInfinite = -1

Functions

func CheckNodeConditionPredicate

func CheckNodeConditionPredicate(node *v1.Node) (bool, []string, error)

func ValidateIsNodeReady

func ValidateIsNodeReady(node *v1.Node) bool

Types

type PriorityQueue

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

func NewPriorityQueue

func NewPriorityQueue(lessFn common_info.LessFn, maxQueueSize int) *PriorityQueue

func (*PriorityQueue) Empty

func (q *PriorityQueue) Empty() bool

func (*PriorityQueue) Fix

func (q *PriorityQueue) Fix(index int)

func (*PriorityQueue) Len

func (q *PriorityQueue) Len() int

func (*PriorityQueue) Peek

func (q *PriorityQueue) Peek() interface{}

func (*PriorityQueue) Pop

func (q *PriorityQueue) Pop() interface{}

func (*PriorityQueue) Push

func (q *PriorityQueue) Push(it interface{})