predicates

Documentation

Index

• Constants
• Variables
• func CapacityPredicate(ctx *algorithm.SchedulingContext, pod *corev1.Pod, node *corev1.Node) (bool, error)
• func LuckyPredicate(pod *corev1.Pod, node *corev1.Node) (bool, []string, error)
• func Predicates(Ctx *algorithm.SchedulingContext, PredicateFuncs []PredicateFunc, ...) (fits bool, failedReasons []string, err error)
• func StorageTypePredicate(ctx *algorithm.SchedulingContext, pod *corev1.Pod, node *corev1.Node) (bool, error)
• type Predicate
  • func NewPredicate(ctx *algorithm.SchedulingContext) *Predicate
  • func (p Predicate) Handler(args schedulerapi.ExtenderArgs) (*schedulerapi.ExtenderFilterResult, error)
• type PredicateFunc

Constants

const (
	// LuckyPred rejects a node if you're not lucky ¯\_(ツ)_/¯
	LuckyPredFailMsg = "Well, you're not lucky"
)

Variables

var (
	// Newly added predicates should be placed here
	DefaultPredicateFuncs = []PredicateFunc{

		StorageTypePredicate,
		CapacityPredicate,
	}
)

Functions

func CapacityPredicate

func CapacityPredicate(ctx *algorithm.SchedulingContext, pod *corev1.Pod, node *corev1.Node) (bool, error)

CapacityPredicate checks if local storage on a node matches the persistent volume claims, follow rules are applied:

1. pvc contains vg or mount point or device claim
2. node free size must larger or equal to pvcs
3. for pvc of type mount point/device: a. must contains more mount points than pvc count

func LuckyPredicate

func LuckyPredicate(pod *corev1.Pod, node *corev1.Node) (bool, []string, error)

func Predicates

func Predicates(Ctx *algorithm.SchedulingContext, PredicateFuncs []PredicateFunc, pod *corev1.Pod, node *corev1.Node) (fits bool, failedReasons []string, err error)

func StorageTypePredicate

func StorageTypePredicate(ctx *algorithm.SchedulingContext, pod *corev1.Pod, node *corev1.Node) (bool, error)

StorageTypePredicate 1. if SPDK support is required, filter out the nodes without SPDK support 2. if SPDK support is unnecessary, filter out the nodes with SPDK support 3. if no volume is required, do nothing

Types

type Predicate

type Predicate struct {
	Name           string
	Ctx            *algorithm.SchedulingContext
	PredicateFuncs []PredicateFunc
}

func NewPredicate

func NewPredicate(ctx *algorithm.SchedulingContext) *Predicate

func (Predicate) Handler

func (p Predicate) Handler(args schedulerapi.ExtenderArgs) (*schedulerapi.ExtenderFilterResult, error)

type PredicateFunc

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