4a72addaeb
Currently, the validation logic validates fields in an object and supply default values wherever applies. This change factors out defaulting to a set of defaulting callback functions for decoding (see #1502 for more discussion). * This change is based on pull request 2587. * Most defaulting has been migrated to defaults.go where the defaulting functions are added. * validation_test.go and converter_test.go have been adapted to not testing the default values. * Fixed all tests with that create invalid objects with the absence of defaulting logic.
126 lines
3.8 KiB
Go
126 lines
3.8 KiB
Go
/*
|
|
Copyright 2014 Google Inc. All rights reserved.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package api
|
|
|
|
import (
|
|
"github.com/GoogleCloudPlatform/kubernetes/pkg/api/resource"
|
|
"github.com/GoogleCloudPlatform/kubernetes/pkg/conversion"
|
|
"github.com/GoogleCloudPlatform/kubernetes/pkg/runtime"
|
|
"github.com/GoogleCloudPlatform/kubernetes/pkg/util"
|
|
)
|
|
|
|
// Codec is the identity codec for this package - it can only convert itself
|
|
// to itself.
|
|
var Codec = runtime.CodecFor(Scheme, "")
|
|
|
|
func init() {
|
|
Scheme.AddConversionFuncs(
|
|
func(in *util.Time, out *util.Time, s conversion.Scope) error {
|
|
// Cannot deep copy these, because time.Time has unexported fields.
|
|
*out = *in
|
|
return nil
|
|
},
|
|
func(in *resource.Quantity, out *resource.Quantity, s conversion.Scope) error {
|
|
// Cannot deep copy these, because inf.Dec has unexported fields.
|
|
*out = *in.Copy()
|
|
return nil
|
|
},
|
|
// Convert ContainerManifest to BoundPod
|
|
func(in *ContainerManifest, out *BoundPod, s conversion.Scope) error {
|
|
out.Spec.Containers = in.Containers
|
|
out.Spec.Volumes = in.Volumes
|
|
out.Spec.RestartPolicy = in.RestartPolicy
|
|
out.Spec.DNSPolicy = in.DNSPolicy
|
|
out.Name = in.ID
|
|
out.UID = in.UUID
|
|
return nil
|
|
},
|
|
func(in *BoundPod, out *ContainerManifest, s conversion.Scope) error {
|
|
out.Containers = in.Spec.Containers
|
|
out.Volumes = in.Spec.Volumes
|
|
out.RestartPolicy = in.Spec.RestartPolicy
|
|
out.DNSPolicy = in.Spec.DNSPolicy
|
|
out.Version = "v1beta2"
|
|
out.ID = in.Name
|
|
out.UUID = in.UID
|
|
return nil
|
|
},
|
|
|
|
// ContainerManifestList
|
|
func(in *ContainerManifestList, out *BoundPods, s conversion.Scope) error {
|
|
if err := s.Convert(&in.Items, &out.Items, 0); err != nil {
|
|
return err
|
|
}
|
|
for i := range out.Items {
|
|
item := &out.Items[i]
|
|
item.ResourceVersion = in.ResourceVersion
|
|
}
|
|
return nil
|
|
},
|
|
func(in *BoundPods, out *ContainerManifestList, s conversion.Scope) error {
|
|
if err := s.Convert(&in.Items, &out.Items, 0); err != nil {
|
|
return err
|
|
}
|
|
out.ResourceVersion = in.ResourceVersion
|
|
return nil
|
|
},
|
|
|
|
// Convert Pod to BoundPod
|
|
func(in *Pod, out *BoundPod, s conversion.Scope) error {
|
|
if err := s.Convert(&in.Spec, &out.Spec, 0); err != nil {
|
|
return err
|
|
}
|
|
// Only copy a subset of fields, and override manifest attributes with the pod
|
|
// metadata
|
|
out.UID = in.UID
|
|
out.Name = in.Name
|
|
out.Namespace = in.Namespace
|
|
out.CreationTimestamp = in.CreationTimestamp
|
|
return nil
|
|
},
|
|
|
|
// Conversion between Manifest and PodSpec
|
|
func(in *PodSpec, out *ContainerManifest, s conversion.Scope) error {
|
|
if err := s.Convert(&in.Volumes, &out.Volumes, 0); err != nil {
|
|
return err
|
|
}
|
|
if err := s.Convert(&in.Containers, &out.Containers, 0); err != nil {
|
|
return err
|
|
}
|
|
if err := s.Convert(&in.RestartPolicy, &out.RestartPolicy, 0); err != nil {
|
|
return err
|
|
}
|
|
out.DNSPolicy = in.DNSPolicy
|
|
out.Version = "v1beta2"
|
|
return nil
|
|
},
|
|
func(in *ContainerManifest, out *PodSpec, s conversion.Scope) error {
|
|
if err := s.Convert(&in.Volumes, &out.Volumes, 0); err != nil {
|
|
return err
|
|
}
|
|
if err := s.Convert(&in.Containers, &out.Containers, 0); err != nil {
|
|
return err
|
|
}
|
|
if err := s.Convert(&in.RestartPolicy, &out.RestartPolicy, 0); err != nil {
|
|
return err
|
|
}
|
|
out.DNSPolicy = in.DNSPolicy
|
|
return nil
|
|
},
|
|
)
|
|
}
|