mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-07 03:03:59 +00:00
cleanup useless functions
This commit is contained in:
parent
24042ce6e7
commit
38de5581b4
@ -254,46 +254,18 @@ func IsIntegerResourceName(str string) bool {
|
|||||||
return integerResources.Has(str) || IsExtendedResourceName(core.ResourceName(str))
|
return integerResources.Has(str) || IsExtendedResourceName(core.ResourceName(str))
|
||||||
}
|
}
|
||||||
|
|
||||||
// Extended and HugePages resources
|
|
||||||
func IsScalarResourceName(name core.ResourceName) bool {
|
|
||||||
return IsExtendedResourceName(name) || IsHugePageResourceName(name)
|
|
||||||
}
|
|
||||||
|
|
||||||
// this function aims to check if the service's ClusterIP is set or not
|
// this function aims to check if the service's ClusterIP is set or not
|
||||||
// the objective is not to perform validation here
|
// the objective is not to perform validation here
|
||||||
func IsServiceIPSet(service *core.Service) bool {
|
func IsServiceIPSet(service *core.Service) bool {
|
||||||
return service.Spec.ClusterIP != core.ClusterIPNone && service.Spec.ClusterIP != ""
|
return service.Spec.ClusterIP != core.ClusterIPNone && service.Spec.ClusterIP != ""
|
||||||
}
|
}
|
||||||
|
|
||||||
// this function aims to check if the service's cluster IP is requested or not
|
|
||||||
func IsServiceIPRequested(service *core.Service) bool {
|
|
||||||
// ExternalName services are CNAME aliases to external ones. Ignore the IP.
|
|
||||||
if service.Spec.Type == core.ServiceTypeExternalName {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
return service.Spec.ClusterIP == ""
|
|
||||||
}
|
|
||||||
|
|
||||||
var standardFinalizers = sets.NewString(
|
var standardFinalizers = sets.NewString(
|
||||||
string(core.FinalizerKubernetes),
|
string(core.FinalizerKubernetes),
|
||||||
metav1.FinalizerOrphanDependents,
|
metav1.FinalizerOrphanDependents,
|
||||||
metav1.FinalizerDeleteDependents,
|
metav1.FinalizerDeleteDependents,
|
||||||
)
|
)
|
||||||
|
|
||||||
// HasAnnotation returns a bool if passed in annotation exists
|
|
||||||
func HasAnnotation(obj core.ObjectMeta, ann string) bool {
|
|
||||||
_, found := obj.Annotations[ann]
|
|
||||||
return found
|
|
||||||
}
|
|
||||||
|
|
||||||
// SetMetaDataAnnotation sets the annotation and value
|
|
||||||
func SetMetaDataAnnotation(obj *core.ObjectMeta, ann string, value string) {
|
|
||||||
if obj.Annotations == nil {
|
|
||||||
obj.Annotations = make(map[string]string)
|
|
||||||
}
|
|
||||||
obj.Annotations[ann] = value
|
|
||||||
}
|
|
||||||
|
|
||||||
func IsStandardFinalizerName(str string) bool {
|
func IsStandardFinalizerName(str string) bool {
|
||||||
return standardFinalizers.Has(str)
|
return standardFinalizers.Has(str)
|
||||||
}
|
}
|
||||||
@ -482,37 +454,6 @@ func AddOrUpdateTolerationInPod(pod *core.Pod, toleration *core.Toleration) bool
|
|||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
|
|
||||||
// TolerationToleratesTaint checks if the toleration tolerates the taint.
|
|
||||||
func TolerationToleratesTaint(toleration *core.Toleration, taint *core.Taint) bool {
|
|
||||||
if len(toleration.Effect) != 0 && toleration.Effect != taint.Effect {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
|
|
||||||
if toleration.Key != taint.Key {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
// TODO: Use proper defaulting when Toleration becomes a field of PodSpec
|
|
||||||
if (len(toleration.Operator) == 0 || toleration.Operator == core.TolerationOpEqual) && toleration.Value == taint.Value {
|
|
||||||
return true
|
|
||||||
}
|
|
||||||
if toleration.Operator == core.TolerationOpExists {
|
|
||||||
return true
|
|
||||||
}
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
|
|
||||||
// TaintToleratedByTolerations checks if taint is tolerated by any of the tolerations.
|
|
||||||
func TaintToleratedByTolerations(taint *core.Taint, tolerations []core.Toleration) bool {
|
|
||||||
tolerated := false
|
|
||||||
for i := range tolerations {
|
|
||||||
if TolerationToleratesTaint(&tolerations[i], taint) {
|
|
||||||
tolerated = true
|
|
||||||
break
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return tolerated
|
|
||||||
}
|
|
||||||
|
|
||||||
// GetTaintsFromNodeAnnotations gets the json serialized taints data from Pod.Annotations
|
// GetTaintsFromNodeAnnotations gets the json serialized taints data from Pod.Annotations
|
||||||
// and converts it to the []Taint type in core.
|
// and converts it to the []Taint type in core.
|
||||||
func GetTaintsFromNodeAnnotations(annotations map[string]string) ([]core.Taint, error) {
|
func GetTaintsFromNodeAnnotations(annotations map[string]string) ([]core.Taint, error) {
|
||||||
|
@ -89,15 +89,6 @@ func IsServiceIPSet(service *v1.Service) bool {
|
|||||||
return service.Spec.ClusterIP != v1.ClusterIPNone && service.Spec.ClusterIP != ""
|
return service.Spec.ClusterIP != v1.ClusterIPNone && service.Spec.ClusterIP != ""
|
||||||
}
|
}
|
||||||
|
|
||||||
// this function aims to check if the service's cluster IP is requested or not
|
|
||||||
func IsServiceIPRequested(service *v1.Service) bool {
|
|
||||||
// ExternalName services are CNAME aliases to external ones. Ignore the IP.
|
|
||||||
if service.Spec.Type == v1.ServiceTypeExternalName {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
return service.Spec.ClusterIP == ""
|
|
||||||
}
|
|
||||||
|
|
||||||
// AddToNodeAddresses appends the NodeAddresses to the passed-by-pointer slice,
|
// AddToNodeAddresses appends the NodeAddresses to the passed-by-pointer slice,
|
||||||
// only if they do not already exist
|
// only if they do not already exist
|
||||||
func AddToNodeAddresses(addresses *[]v1.NodeAddress, addAddresses ...v1.NodeAddress) {
|
func AddToNodeAddresses(addresses *[]v1.NodeAddress, addAddresses ...v1.NodeAddress) {
|
||||||
@ -416,20 +407,6 @@ func GetPersistentVolumeClaimClass(claim *v1.PersistentVolumeClaim) string {
|
|||||||
return ""
|
return ""
|
||||||
}
|
}
|
||||||
|
|
||||||
// PersistentVolumeClaimHasClass returns true if given claim has set StorageClassName field.
|
|
||||||
func PersistentVolumeClaimHasClass(claim *v1.PersistentVolumeClaim) bool {
|
|
||||||
// Use beta annotation first
|
|
||||||
if _, found := claim.Annotations[v1.BetaStorageClassAnnotation]; found {
|
|
||||||
return true
|
|
||||||
}
|
|
||||||
|
|
||||||
if claim.Spec.StorageClassName != nil {
|
|
||||||
return true
|
|
||||||
}
|
|
||||||
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
|
|
||||||
// GetStorageNodeAffinityFromAnnotation gets the json serialized data from PersistentVolume.Annotations
|
// GetStorageNodeAffinityFromAnnotation gets the json serialized data from PersistentVolume.Annotations
|
||||||
// and converts it to the NodeAffinity type in api.
|
// and converts it to the NodeAffinity type in api.
|
||||||
// TODO: update when storage node affinity graduates to beta
|
// TODO: update when storage node affinity graduates to beta
|
||||||
|
Loading…
Reference in New Issue
Block a user