predicates

Documentation

Index

• Constants
• func CollectEvents(source <-chan string) []string
• func GetNodeNames(nodes []apiv1.Node) []string
• type FakePredicate
  • func NewFakePredicate(name string, nodes []v1.Node, err error) *FakePredicate
  • func (f *FakePredicate) Filter(_ string, _ *v1.Pod, nodes []v1.Node) ([]v1.Node, error)
  • func (f *FakePredicate) Name() 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 CollectEvents

func CollectEvents(source <-chan string) []string

func GetNodeNames

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

Types

type FakePredicate

type FakePredicate struct {
	FakeName string
	Nodes    []v1.Node
	Err      error
}

func NewFakePredicate

func NewFakePredicate(name string, nodes []v1.Node, err error) *FakePredicate

func (*FakePredicate) Filter

func (f *FakePredicate) Filter(_ string, _ *v1.Pod, nodes []v1.Node) ([]v1.Node, error)

func (*FakePredicate) Name

func (f *FakePredicate) Name() string

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) Predicate

NewHA returns a Predicate

func NewStableScheduling

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

NewStableScheduling returns a Predicate