priorities

Documentation

Index

• Variables
• func CapacityMatch(ctx *algorithm.SchedulingContext, pod *corev1.Pod, node *corev1.Node) (int, error)
• func CountMatch(ctx *algorithm.SchedulingContext, pod *corev1.Pod, node *corev1.Node) (int, error)
• func InitHostPriorityList(nodeNames []string) schedulerapi.HostPriorityList
• func NodeAntiAffinity(ctx *algorithm.SchedulingContext, pod *corev1.Pod, node *corev1.Node) (int, error)
• type Prioritize
  • func NewPrioritize(ctx *algorithm.SchedulingContext) *Prioritize
  • func (p Prioritize) Handler(args schedulerapi.ExtenderArgs) (*schedulerapi.HostPriorityList, error)
• type PrioritizeFunc

Variables

var (
	// Newly added predicates should be placed here
	DefaultPrioritizeFuncs = []PrioritizeFunc{

		CapacityMatch,
		CountMatch,
		NodeAntiAffinity,
	}
)

Functions

func CapacityMatch

func CapacityMatch(ctx *algorithm.SchedulingContext, pod *corev1.Pod, node *corev1.Node) (int, error)

func CountMatch

func CountMatch(ctx *algorithm.SchedulingContext, pod *corev1.Pod, node *corev1.Node) (int, error)

CountMatch picks the node whose amount of device/mount point best fulfill the amount of pvc requests

func InitHostPriorityList

func InitHostPriorityList(nodeNames []string) schedulerapi.HostPriorityList

func NodeAntiAffinity

func NodeAntiAffinity(ctx *algorithm.SchedulingContext, pod *corev1.Pod, node *corev1.Node) (int, error)

NodeAntiAffinity picks the node whose amount of device/mount point best fulfill the amount of pvc requests

Types

type Prioritize

type Prioritize struct {
	Name            string
	Ctx             *algorithm.SchedulingContext
	PrioritizeFuncs []PrioritizeFunc
}

func NewPrioritize

func NewPrioritize(ctx *algorithm.SchedulingContext) *Prioritize

func (Prioritize) Handler

func (p Prioritize) Handler(args schedulerapi.ExtenderArgs) (*schedulerapi.HostPriorityList, error)

type PrioritizeFunc

type PrioritizeFunc func(ctx *algorithm.SchedulingContext, pod *corev1.Pod, node *corev1.Node) (int, error)