predicates

Dec 14, 2017

Changes in this version

+ const AzureDiskVolumeFilterType

+ const CheckVolumeBinding

+ const DefaultMaxAzureDiskVolumes

+ const DefaultMaxGCEPDVolumes

+ const EBSVolumeFilterType

+ const GCEPDVolumeFilterType

+ const KubeMaxPDVols

+ var ErrExistingPodsAntiAffinityRulesNotMatch = newPredicateFailureError("ExistingPodsAntiAffinityRulesNotMatch")

+ var ErrPodAffinityRulesNotMatch = newPredicateFailureError("PodAffinityRulesNotMatch")

+ var ErrPodAntiAffinityRulesNotMatch = newPredicateFailureError("PodAntiAffinityRulesNotMatch")

+ var ErrVolumeBindConflict = newPredicateFailureError("VolumeBindingNoMatch")

+ func GetPodAffinityTerms(podAffinity *v1.PodAffinity) (terms []v1.PodAffinityTerm)

+ func GetPodAntiAffinityTerms(podAntiAffinity *v1.PodAntiAffinity) (terms []v1.PodAffinityTerm)

+ func NewVolumeBindingPredicate(binder *volumebinder.VolumeBinder) algorithm.FitPredicate

+ type CachedStorageClassInfo struct

+ func (c *CachedStorageClassInfo) GetStorageClassInfo(className string) (*storagev1.StorageClass, error)

+ type FakeStorageClassInfo []storagev1.StorageClass

+ func (classes FakeStorageClassInfo) GetStorageClassInfo(name string) (*storagev1.StorageClass, error)

+ type StorageClassInfo interface

+ GetStorageClassInfo func(className string) (*storagev1.StorageClass, error)

+ type VolumeBindingChecker struct

Jan 15, 2018

Changes in this version

+ func NewEquivalencePodGenerator(pvcInfo PersistentVolumeClaimInfo) algorithm.GetEquivalencePodFunc

type EquivalencePod

+ PVCSet sets.String

+ type EquivalencePodGenerator struct

+ type FakeNodeInfo v1.Node

+ func (n FakeNodeInfo) GetNodeInfo(nodeName string) (*v1.Node, error)

+ type FakeNodeListInfo []v1.Node

+ func (nodes FakeNodeListInfo) GetNodeInfo(nodeName string) (*v1.Node, error)

+ type FakePersistentVolumeClaimInfo []v1.PersistentVolumeClaim

+ func (pvcs FakePersistentVolumeClaimInfo) GetPersistentVolumeClaimInfo(namespace string, pvcID string) (*v1.PersistentVolumeClaim, error)

+ type FakePersistentVolumeInfo []v1.PersistentVolume

+ func (pvs FakePersistentVolumeInfo) GetPersistentVolumeInfo(pvID string) (*v1.PersistentVolume, error)

Sep 28, 2017

Changes in this version

+ const MatchInterPodAffinity

+ var ErrNodeNetworkUnavailable = newPredicateFailureError("NodeNetworkUnavailable")

+ var ErrNodeNotReady = newPredicateFailureError("NodeNotReady")

+ var ErrNodeOutOfDisk = newPredicateFailureError("NodeOutOfDisk")

+ var ErrNodeUnknownCondition = newPredicateFailureError("NodeUnknownCondition")

+ var ErrNodeUnschedulable = newPredicateFailureError("NodeUnschedulable")

+ func CheckNodeConditionPredicate(pod *v1.Pod, meta algorithm.PredicateMetadata, ...) (bool, []algorithm.PredicateFailureReason, error)

+ func GetEquivalencePod(pod *v1.Pod) interface

+ func RegisterPredicateMetadataProducer(predicateName string, precomp PredicateMetadataProducer)

+ type EquivalencePod struct

+ ControllerRef metav1.OwnerReference

+ type PredicateMetadataProducer func(pm *predicateMetadata)

Oct 5, 2017

Changes in this version

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

Jun 29, 2017

Changes in this version

+ var ErrVolumeNodeConflict = newPredicateFailureError("NoVolumeNodeConflict")

+ func NewVolumeNodePredicate(pvInfo PersistentVolumeInfo, pvcInfo PersistentVolumeClaimInfo, ...) algorithm.FitPredicate

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

+ type VolumeNodeChecker struct

Mar 28, 2017

Changes in this version

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

+ type CachedPersistentVolumeInfo struct

+ func (c *CachedPersistentVolumeInfo) GetPersistentVolumeInfo(pvID string) (*v1.PersistentVolume, error)

type InsufficientResourceError

+ func (e *InsufficientResourceError) GetInsufficientAmount() int64

type VolumeFilter

+ var AzureDiskVolumeFilter VolumeFilter = VolumeFilter{ ... }

Dec 14, 2016

Changes in this version

+ func AddUnsetLabelsToMap(aL map[string]string, labelsToAdd []string, labelSet labels.Set)

+ func CreateSelectorFromLabels(aL map[string]string) labels.Selector

+ func FilterPodsByNamespace(pods []*api.Pod, ns string) []*api.Pod

+ func FindLabelsInSet(labelsToKeep []string, selector labels.Set) map[string]string

+ func GetResourceRequest(pod *api.Pod) *schedulercache.Resource

+ func GetUsedPorts(pods ...*api.Pod) map[int]bool

+ func NewPredicateMetadataFactory(podLister algorithm.PodLister) algorithm.MetadataProducer

+ func RegisterPredicatePrecomputation(predicateName string, precomp PredicateMetadataModifier)

+ type CachedPersistentVolumeClaimInfo struct

+ func (c *CachedPersistentVolumeClaimInfo) GetPersistentVolumeClaimInfo(namespace string, name string) (*api.PersistentVolumeClaim, error)

+ type PredicateMetadataFactory struct

+ func (pfactory *PredicateMetadataFactory) GetMetadata(pod *api.Pod, nodeNameToInfoMap map[string]*schedulercache.NodeInfo) interface{}

+ type PredicateMetadataModifier func(pm *predicateMetadata)

Oct 15, 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)

Apr 22, 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

Jan 27, 2016

Changes in this version

+ var FailedResourceType string

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

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

Jun 8, 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)