predicates

Documentation

Index

• Constants
• func GetNodeNames(nodes []apiv1.Node) []string
• type Predicate
  • func NewHA(kubeCli kubernetes.Interface, cli versioned.Interface, ...) Predicate
  • func NewStableScheduling(kubeCli kubernetes.Interface, cli versioned.Interface, ...) Predicate

Constants

const (
	// UnableToRunOnPreviousNodeReason represents the reason of event that we
	// cannot schedule the new pod of component member to its previous node.
	UnableToRunOnPreviousNodeReason = "UnableToRunOnPreviousNode"
)

Functions

func GetNodeNames

func GetNodeNames(nodes []apiv1.Node) []string

Types

type Predicate

type Predicate interface {
	// Name return the predicate name
	Name() string

	// Filter function receives a set of nodes and returns a set of candidate nodes.
	Filter(string, *apiv1.Pod, []apiv1.Node) ([]apiv1.Node, error)
}

Predicate is an interface as extender-implemented predicate functions

func NewHA

func NewHA(kubeCli kubernetes.Interface, cli versioned.Interface, recorder record.EventRecorder) Predicate

NewHA returns a Predicate

func NewStableScheduling

func NewStableScheduling(kubeCli kubernetes.Interface, cli versioned.Interface, recorder record.EventRecorder) Predicate

NewStableScheduling returns a Predicate