github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-20 17:38:50 +00:00
Code Issues Projects Releases Wiki Activity

Remove redundant code in validation

Browse Source
This commit is contained in:
derekwaynecarr
2014-10-01 14:29:47 -04:00
parent 6625e58a20
commit 016d394705
1 changed files with 9 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
pkg/api/validation/validation.go
View File

@@ -313,7 +313,9 @@ func ValidatePod(pod *api.Pod) errs.ErrorList {
if len(pod.ID) == 0 { if len(pod.ID) == 0 {
allErrs = append(allErrs, errs.NewFieldRequired("id", pod.ID)) allErrs = append(allErrs, errs.NewFieldRequired("id", pod.ID))
} }
allErrs = append(allErrs, validateNotEmptyDNSSubdomain(pod.Namespace, "pod.Namespace")...) if !util.IsDNSSubdomain(pod.Namespace) {
allErrs = append(allErrs, errs.NewFieldInvalid("pod.Namespace", pod.Namespace))
}
allErrs = append(allErrs, ValidatePodState(&pod.DesiredState).Prefix("desiredState")...) allErrs = append(allErrs, ValidatePodState(&pod.DesiredState).Prefix("desiredState")...)
return allErrs return allErrs
} }
@@ -326,7 +328,9 @@ func ValidateService(service *api.Service) errs.ErrorList {
} else if !util.IsDNS952Label(service.ID) { } else if !util.IsDNS952Label(service.ID) {
allErrs = append(allErrs, errs.NewFieldInvalid("id", service.ID)) allErrs = append(allErrs, errs.NewFieldInvalid("id", service.ID))
} }
allErrs = append(allErrs, validateNotEmptyDNSSubdomain(service.Namespace, "service.Namespace")...) if !util.IsDNSSubdomain(service.Namespace) {
allErrs = append(allErrs, errs.NewFieldInvalid("service.Namespace", service.Namespace))
}
if !util.IsValidPortNum(service.Port) { if !util.IsValidPortNum(service.Port) {
allErrs = append(allErrs, errs.NewFieldInvalid("Service.Port", service.Port)) allErrs = append(allErrs, errs.NewFieldInvalid("Service.Port", service.Port))
} }
@@ -347,7 +351,9 @@ func ValidateReplicationController(controller *api.ReplicationController) errs.E
if len(controller.ID) == 0 { if len(controller.ID) == 0 {
allErrs = append(allErrs, errs.NewFieldRequired("id", controller.ID)) allErrs = append(allErrs, errs.NewFieldRequired("id", controller.ID))
} }
allErrs = append(allErrs, validateNotEmptyDNSSubdomain(controller.Namespace, "controller.Namespace")...) if !util.IsDNSSubdomain(controller.Namespace) {
allErrs = append(allErrs, errs.NewFieldInvalid("controller.Namespace", controller.Namespace))
}
allErrs = append(allErrs, ValidateReplicationControllerState(&controller.DesiredState).Prefix("desiredState")...) allErrs = append(allErrs, ValidateReplicationControllerState(&controller.DesiredState).Prefix("desiredState")...)
return allErrs return allErrs
} }
@@ -369,14 +375,3 @@ func ValidateReplicationControllerState(state *api.ReplicationControllerState) e
allErrs = append(allErrs, ValidateManifest(&state.PodTemplate.DesiredState.Manifest).Prefix("podTemplate.desiredState.manifest")...) allErrs = append(allErrs, ValidateManifest(&state.PodTemplate.DesiredState.Manifest).Prefix("podTemplate.desiredState.manifest")...)
return allErrs return allErrs
} }
// validateNotEmptyDNSSubdomain validates the provided value is not empty and is a dns subdomain.
func validateNotEmptyDNSSubdomain(value string, label string) errs.ErrorList {
allErrs := errs.ErrorList{}
if value == "" {
allErrs = append(allErrs, errs.NewFieldInvalid(label, value))
} else if !util.IsDNSSubdomain(value) {
allErrs = append(allErrs, errs.NewFieldInvalid(label, value))
}
return allErrs
}