predicates

Sep 25, 2018

Changes in this version

+ const MaxCSIVolumeCountPred

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

+ type CSIMaxVolumeLimitChecker struct

Aug 7, 2018

Changes in this version

+ const CheckNodePIDPressurePred

+ var ErrNodeUnderPIDPressure = newPredicateFailureError("NodeUnderPIDPressure", "node(s) had pid pressure")

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

Mar 23, 2018

Changes in this version

+ const AzureDiskVolumeFilterType

+ const CheckNodeConditionPred

+ const CheckNodeDiskPressurePred

+ const CheckNodeLabelPresencePred

+ const CheckNodeMemoryPressurePred

+ const CheckNodeUnschedulablePred

+ const CheckServiceAffinityPred

+ const CheckVolumeBindingPred

+ const DefaultMaxAzureDiskVolumes

+ const DefaultMaxEBSVolumes

+ const DefaultMaxGCEPDVolumes

+ const EBSVolumeFilterType

+ const GCEPDVolumeFilterType

+ const GeneralPred

+ const HostNamePred

+ const KubeMaxPDVols

+ const MatchInterPodAffinityPred

+ const MatchNodeSelectorPred

+ const MaxAzureDiskVolumeCountPred

+ const MaxEBSVolumeCountPred

+ const MaxGCEPDVolumeCountPred

+ const NoDiskConflictPred

+ const NoVolumeZoneConflictPred

+ const PodFitsHostPortsPred

+ const PodFitsResourcesPred

+ const PodToleratesNodeNoExecuteTaintsPred

+ const PodToleratesNodeTaintsPred

+ var AzureDiskVolumeFilter = VolumeFilter

+ var EBSVolumeFilter = VolumeFilter

+ var ErrDiskConflict = newPredicateFailureError("NoDiskConflict", "node(s) had no available disk")

+ var ErrExistingPodsAntiAffinityRulesNotMatch = newPredicateFailureError("ExistingPodsAntiAffinityRulesNotMatch", ...)

+ var ErrFakePredicate = newPredicateFailureError("FakePredicateError", "Nodes failed the fake predicate")

+ var ErrMaxVolumeCountExceeded = newPredicateFailureError("MaxVolumeCount", "node(s) exceed max volume count")

+ var ErrNodeLabelPresenceViolated = newPredicateFailureError("CheckNodeLabelPresence", "node(s) didn't have the requested labels")

+ var ErrNodeNetworkUnavailable = newPredicateFailureError("NodeNetworkUnavailable", "node(s) had unavailable network")

+ var ErrNodeNotReady = newPredicateFailureError("NodeNotReady", "node(s) were not ready")

+ var ErrNodeOutOfDisk = newPredicateFailureError("NodeOutOfDisk", "node(s) were out of disk space")

+ var ErrNodeSelectorNotMatch = newPredicateFailureError("MatchNodeSelector", "node(s) didn't match node selector")

+ var ErrNodeUnderDiskPressure = newPredicateFailureError("NodeUnderDiskPressure", "node(s) had disk pressure")

+ var ErrNodeUnderMemoryPressure = newPredicateFailureError("NodeUnderMemoryPressure", "node(s) had memory pressure")

+ var ErrNodeUnknownCondition = newPredicateFailureError("NodeUnknownCondition", "node(s) had unknown conditions")

+ var ErrNodeUnschedulable = newPredicateFailureError("NodeUnschedulable", "node(s) were unschedulable")

+ var ErrPodAffinityNotMatch = newPredicateFailureError("MatchInterPodAffinity", "node(s) didn't match pod affinity/anti-affinity")

+ var ErrPodAffinityRulesNotMatch = newPredicateFailureError("PodAffinityRulesNotMatch", "node(s) didn't match pod affinity rules")

+ var ErrPodAntiAffinityRulesNotMatch = newPredicateFailureError("PodAntiAffinityRulesNotMatch", "node(s) didn't match pod anti-affinity rules")

+ var ErrPodNotFitsHostPorts = newPredicateFailureError("PodFitsHostPorts", ...)

+ var ErrPodNotMatchHostName = newPredicateFailureError("HostName", "node(s) didn't match the requested hostname")

+ var ErrServiceAffinityViolated = newPredicateFailureError("CheckServiceAffinity", "node(s) didn't match service affinity")

+ var ErrTaintsTolerationsNotMatch = newPredicateFailureError("PodToleratesNodeTaints", "node(s) had taints that the pod didn't tolerate")

+ var ErrVolumeBindConflict = newPredicateFailureError("VolumeBindingNoMatch", ...)

+ var ErrVolumeNodeConflict = newPredicateFailureError("VolumeNodeAffinityConflict", "node(s) had volume node affinity conflict")

+ var ErrVolumeZoneConflict = newPredicateFailureError("NoVolumeZoneConflict", "node(s) had no available volume zone")

+ var GCEPDVolumeFilter = VolumeFilter

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func NewEquivalencePodGenerator(pvcInfo PersistentVolumeClaimInfo) algorithm.GetEquivalencePodFunc

+ func NewMaxPDVolumeCountPredicate(filterName string, pvInfo PersistentVolumeInfo, ...) algorithm.FitPredicate

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

+ func NewPodAffinityPredicate(info NodeInfo, podLister algorithm.PodLister) algorithm.FitPredicate

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

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

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

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

+ func Ordering() []string

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

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

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

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

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

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

+ func RegisterPredicateMetadataProducer(predicateName string, precomp PredicateMetadataProducer)

+ func RegisterPredicateMetadataProducerWithExtendedResourceOptions(ignoredExtendedResources sets.String)

+ func SetPredicatesOrdering(names []string)

+ type CachedNodeInfo struct

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

+ type CachedPersistentVolumeClaimInfo struct

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

+ type CachedPersistentVolumeInfo struct

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

+ type CachedStorageClassInfo struct

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

+ type EquivalencePod struct

+ ControllerRef metav1.OwnerReference

+ PVCSet sets.String

+ type EquivalencePodGenerator struct

+ type FailureReason struct

+ func NewFailureReason(msg string) *FailureReason

+ func (e *FailureReason) GetReason() string

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

+ type FakeStorageClassInfo []storagev1.StorageClass

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

+ type InsufficientResourceError struct

+ ResourceName v1.ResourceName

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

+ func (e *InsufficientResourceError) Error() string

+ func (e *InsufficientResourceError) GetInsufficientAmount() int64

+ func (e *InsufficientResourceError) GetReason() string

+ type MaxPDVolumeCountChecker struct

+ type NodeInfo interface

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

+ type NodeLabelChecker struct

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

+ type PersistentVolumeClaimInfo interface

+ GetPersistentVolumeClaimInfo func(namespace string, name string) (*v1.PersistentVolumeClaim, error)

+ type PersistentVolumeInfo interface

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

+ type PodAffinityChecker struct

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

+ type PredicateFailureError struct

+ PredicateDesc string

+ PredicateName string

+ func (e *PredicateFailureError) Error() string

+ func (e *PredicateFailureError) GetReason() string

+ type PredicateMetadataFactory struct

+ func (pfactory *PredicateMetadataFactory) GetMetadata(pod *v1.Pod, nodeNameToInfoMap map[string]*schedulercache.NodeInfo) algorithm.PredicateMetadata

+ type PredicateMetadataProducer func(pm *predicateMetadata)

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

+ type ServiceAffinity struct

+ type StorageClassInfo interface

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

+ type VolumeBindingChecker struct

+ type VolumeFilter struct

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

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

+ type VolumeZoneChecker struct