predicates

Sep 26, 2016

Changes in this version

+ var ErrNodeUnderDiskPressure = newPredicateFailureError("NodeUnderDiskPressure")

+ func CheckNodeDiskPressurePredicate(pod *api.Pod, meta interface{}, nodeInfo *schedulercache.NodeInfo) (bool, []algorithm.PredicateFailureReason, error)

+ func PodToleratesNodeTaints(pod *api.Pod, meta interface{}, nodeInfo *schedulercache.NodeInfo) (bool, []algorithm.PredicateFailureReason, error)

+ func PredicateMetadata(pod *api.Pod, nodeInfoMap map[string]*schedulercache.NodeInfo) interface

+ type FailureReason struct

+ func NewFailureReason(msg string) *FailureReason

+ func (e *FailureReason) GetReason() string

type InsufficientResourceError

+ func NewInsufficientResourceError(resourceName api.ResourceName, requested, used, capacity int64) *InsufficientResourceError

+ func (e *InsufficientResourceError) GetReason() string

type PredicateFailureError

+ func (e *PredicateFailureError) GetReason() string

Jul 1, 2016

Changes in this version

+ var ErrDiskConflict = newPredicateFailureError("NoDiskConflict")

+ var ErrFakePredicate = newPredicateFailureError("FakePredicateError")

+ var ErrMaxVolumeCountExceeded = newPredicateFailureError("MaxVolumeCount")

+ var ErrNodeLabelPresenceViolated = newPredicateFailureError("CheckNodeLabelPresence")

+ var ErrNodeSelectorNotMatch = newPredicateFailureError("MatchNodeSelector")

+ var ErrNodeUnderMemoryPressure = newPredicateFailureError("NodeUnderMemoryPressure")

+ var ErrPodAffinityNotMatch = newPredicateFailureError("MatchInterPodAffinity")

+ var ErrPodNotFitsHostPorts = newPredicateFailureError("PodFitsHostPorts")

+ var ErrPodNotMatchHostName = newPredicateFailureError("HostName")

+ var ErrServiceAffinityViolated = newPredicateFailureError("CheckServiceAffinity")

+ var ErrTaintsTolerationsNotMatch = newPredicateFailureError("PodToleratesNodeTaints")

+ var ErrVolumeZoneConflict = newPredicateFailureError("NoVolumeZoneConflict")

+ func CheckNodeMemoryPressurePredicate(pod *api.Pod, nodeInfo *schedulercache.NodeInfo) (bool, error)

+ func GeneralPredicates(pod *api.Pod, nodeInfo *schedulercache.NodeInfo) (bool, error)

+ func NewPodAffinityPredicate(info NodeInfo, podLister algorithm.PodLister, failureDomains []string) algorithm.FitPredicate

+ func NewTolerationMatchPredicate(info NodeInfo) algorithm.FitPredicate

+ func PodFitsResources(pod *api.Pod, nodeInfo *schedulercache.NodeInfo) (bool, error)

+ func PodSelectorMatches(pod *api.Pod, nodeInfo *schedulercache.NodeInfo) (bool, error)

type InsufficientResourceError

+ ResourceName string

+ type PodAffinityChecker struct

+ func (checker *PodAffinityChecker) AnyPodMatchesPodAffinityTerm(pod *api.Pod, allPods []*api.Pod, node *api.Node, ...) (bool, error)

+ func (checker *PodAffinityChecker) InterPodAffinityMatches(pod *api.Pod, nodeInfo *schedulercache.NodeInfo) (bool, error)

+ func (checker *PodAffinityChecker) NodeMatchPodAffinityAntiAffinity(pod *api.Pod, allPods []*api.Pod, node *api.Node) bool

+ func (checker *PodAffinityChecker) NodeMatchesHardPodAffinity(pod *api.Pod, allPods []*api.Pod, node *api.Node, podAffinity *api.PodAffinity) bool

+ func (checker *PodAffinityChecker) NodeMatchesHardPodAntiAffinity(pod *api.Pod, allPods []*api.Pod, node *api.Node, ...) bool

+ type PredicateFailureError struct

+ PredicateName string

+ func (e *PredicateFailureError) Error() string

+ type TolerationMatch struct

+ func (t *TolerationMatch) PodToleratesNodeTaints(pod *api.Pod, nodeInfo *schedulercache.NodeInfo) (bool, error)

Mar 16, 2016

Changes in this version

+ func NewMaxPDVolumeCountPredicate(filter VolumeFilter, maxVolumes int, pvInfo PersistentVolumeInfo, ...) algorithm.FitPredicate

+ func NewVolumeZonePredicate(nodeInfo NodeInfo, pvInfo PersistentVolumeInfo, ...) algorithm.FitPredicate

+ type CachedNodeInfo struct

+ func (c *CachedNodeInfo) GetNodeInfo(id string) (*api.Node, error)

+ type InsufficientResourceError struct

+ func (e *InsufficientResourceError) Error() string

+ type MaxPDVolumeCountChecker struct

+ type PersistentVolumeClaimInfo interface

+ GetPersistentVolumeClaimInfo func(namespace string, pvcID string) (*api.PersistentVolumeClaim, error)

+ type PersistentVolumeInfo interface

+ GetPersistentVolumeInfo func(pvID string) (*api.PersistentVolume, error)

+ type VolumeFilter struct

+ FilterPersistentVolume func(pv *api.PersistentVolume) (id string, relevant bool)

+ FilterVolume func(vol *api.Volume) (id string, relevant bool)

+ var EBSVolumeFilter VolumeFilter = VolumeFilter{ ... }

+ var GCEPDVolumeFilter VolumeFilter = VolumeFilter{ ... }

+ type VolumeZoneChecker struct

Nov 9, 2015

Changes in this version

+ func PodFitsHostPorts(pod *api.Pod, existingPods []*api.Pod, node string) (bool, error)

Sep 25, 2015

Changes in this version

+ var FailedResourceType string

+ func CheckPodsExceedingFreeResources(pods []*api.Pod, capacity api.ResourceList) (fitting []*api.Pod, notFittingCPU, notFittingMemory []*api.Pod)

May 29, 2015

Changes in this version

+ func CheckPodsExceedingCapacity(pods []*api.Pod, capacity api.ResourceList) (fitting []*api.Pod, notFitting []*api.Pod)

+ func MapPodsToMachines(lister algorithm.PodLister) (map[string][]*api.Pod, error)

+ func NewNodeLabelPredicate(info NodeInfo, labels []string, presence bool) algorithm.FitPredicate

+ func NewResourceFitPredicate(info NodeInfo) algorithm.FitPredicate

+ func NewSelectorMatchPredicate(info NodeInfo) algorithm.FitPredicate

+ func NewServiceAffinityPredicate(podLister algorithm.PodLister, serviceLister algorithm.ServiceLister, ...) algorithm.FitPredicate

+ func NoDiskConflict(pod *api.Pod, existingPods []*api.Pod, node string) (bool, error)

+ func PodFitsHost(pod *api.Pod, existingPods []*api.Pod, node string) (bool, error)

+ func PodFitsPorts(pod *api.Pod, existingPods []*api.Pod, node string) (bool, error)

+ func PodMatchesNodeLabels(pod *api.Pod, node *api.Node) bool

+ type ClientNodeInfo struct

+ func (nodes ClientNodeInfo) GetNodeInfo(nodeID string) (*api.Node, error)

+ type NodeInfo interface

+ GetNodeInfo func(nodeID string) (*api.Node, error)

+ type NodeLabelChecker struct

+ func (n *NodeLabelChecker) CheckNodeLabelPresence(pod *api.Pod, existingPods []*api.Pod, node string) (bool, error)

+ type NodeSelector struct

+ func (n *NodeSelector) PodSelectorMatches(pod *api.Pod, existingPods []*api.Pod, node string) (bool, error)

+ type ResourceFit struct

+ func (r *ResourceFit) PodFitsResources(pod *api.Pod, existingPods []*api.Pod, node string) (bool, error)

+ type ServiceAffinity struct

+ func (s *ServiceAffinity) CheckServiceAffinity(pod *api.Pod, existingPods []*api.Pod, node string) (bool, error)

+ type StaticNodeInfo struct

+ func (nodes StaticNodeInfo) GetNodeInfo(nodeID string) (*api.Node, error)