123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564 |
- /*
- Copyright 2016 The Kubernetes Authors.
- 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 v1beta2
- import (
- "fmt"
- "strconv"
- appsv1beta2 "k8s.io/api/apps/v1beta2"
- "k8s.io/api/core/v1"
- metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
- "k8s.io/apimachinery/pkg/conversion"
- "k8s.io/apimachinery/pkg/labels"
- "k8s.io/apimachinery/pkg/runtime"
- "k8s.io/apimachinery/pkg/util/intstr"
- "k8s.io/kubernetes/pkg/apis/apps"
- autoscaling "k8s.io/kubernetes/pkg/apis/autoscaling"
- api "k8s.io/kubernetes/pkg/apis/core"
- k8s_api_v1 "k8s.io/kubernetes/pkg/apis/core/v1"
- )
- func addConversionFuncs(scheme *runtime.Scheme) error {
- // Add non-generated conversion functions to handle the *int32 -> int32
- // conversion. A pointer is useful in the versioned type so we can default
- // it, but a plain int32 is more convenient in the internal type. These
- // functions are the same as the autogenerated ones in every other way.
- err := scheme.AddConversionFuncs(
- Convert_v1beta2_StatefulSetSpec_To_apps_StatefulSetSpec,
- Convert_apps_StatefulSetSpec_To_v1beta2_StatefulSetSpec,
- Convert_v1beta2_StatefulSetUpdateStrategy_To_apps_StatefulSetUpdateStrategy,
- Convert_apps_StatefulSetUpdateStrategy_To_v1beta2_StatefulSetUpdateStrategy,
- Convert_apps_RollingUpdateDaemonSet_To_v1beta2_RollingUpdateDaemonSet,
- Convert_v1beta2_RollingUpdateDaemonSet_To_apps_RollingUpdateDaemonSet,
- Convert_v1beta2_StatefulSetStatus_To_apps_StatefulSetStatus,
- Convert_apps_StatefulSetStatus_To_v1beta2_StatefulSetStatus,
- Convert_v1beta2_Deployment_To_apps_Deployment,
- Convert_apps_Deployment_To_v1beta2_Deployment,
- Convert_apps_DaemonSet_To_v1beta2_DaemonSet,
- Convert_v1beta2_DaemonSet_To_apps_DaemonSet,
- Convert_apps_DaemonSetSpec_To_v1beta2_DaemonSetSpec,
- Convert_v1beta2_DaemonSetSpec_To_apps_DaemonSetSpec,
- Convert_apps_DaemonSetUpdateStrategy_To_v1beta2_DaemonSetUpdateStrategy,
- Convert_v1beta2_DaemonSetUpdateStrategy_To_apps_DaemonSetUpdateStrategy,
- // extensions
- // TODO: below conversions should be dropped in favor of auto-generated
- // ones, see https://github.com/kubernetes/kubernetes/issues/39865
- Convert_v1beta2_ScaleStatus_To_autoscaling_ScaleStatus,
- Convert_autoscaling_ScaleStatus_To_v1beta2_ScaleStatus,
- Convert_v1beta2_DeploymentSpec_To_apps_DeploymentSpec,
- Convert_apps_DeploymentSpec_To_v1beta2_DeploymentSpec,
- Convert_v1beta2_DeploymentStrategy_To_apps_DeploymentStrategy,
- Convert_apps_DeploymentStrategy_To_v1beta2_DeploymentStrategy,
- Convert_v1beta2_RollingUpdateDeployment_To_apps_RollingUpdateDeployment,
- Convert_apps_RollingUpdateDeployment_To_v1beta2_RollingUpdateDeployment,
- Convert_apps_ReplicaSetSpec_To_v1beta2_ReplicaSetSpec,
- Convert_v1beta2_ReplicaSetSpec_To_apps_ReplicaSetSpec,
- )
- if err != nil {
- return err
- }
- // Add field label conversions for kinds having selectable nothing but ObjectMeta fields.
- err = scheme.AddFieldLabelConversionFunc(SchemeGroupVersion.WithKind("StatefulSet"),
- func(label, value string) (string, string, error) {
- switch label {
- case "metadata.name", "metadata.namespace", "status.successful":
- return label, value, nil
- default:
- return "", "", fmt.Errorf("field label not supported for appsv1beta2.StatefulSet: %s", label)
- }
- })
- if err != nil {
- return err
- }
- return nil
- }
- func Convert_apps_RollingUpdateDaemonSet_To_v1beta2_RollingUpdateDaemonSet(in *apps.RollingUpdateDaemonSet, out *appsv1beta2.RollingUpdateDaemonSet, s conversion.Scope) error {
- if out.MaxUnavailable == nil {
- out.MaxUnavailable = &intstr.IntOrString{}
- }
- if err := s.Convert(&in.MaxUnavailable, out.MaxUnavailable, 0); err != nil {
- return err
- }
- return nil
- }
- func Convert_v1beta2_RollingUpdateDaemonSet_To_apps_RollingUpdateDaemonSet(in *appsv1beta2.RollingUpdateDaemonSet, out *apps.RollingUpdateDaemonSet, s conversion.Scope) error {
- if err := s.Convert(in.MaxUnavailable, &out.MaxUnavailable, 0); err != nil {
- return err
- }
- return nil
- }
- func Convert_v1beta2_StatefulSetSpec_To_apps_StatefulSetSpec(in *appsv1beta2.StatefulSetSpec, out *apps.StatefulSetSpec, s conversion.Scope) error {
- if in.Replicas != nil {
- out.Replicas = *in.Replicas
- }
- if in.Selector != nil {
- in, out := &in.Selector, &out.Selector
- *out = new(metav1.LabelSelector)
- if err := s.Convert(*in, *out, 0); err != nil {
- return err
- }
- } else {
- out.Selector = nil
- }
- if err := k8s_api_v1.Convert_v1_PodTemplateSpec_To_core_PodTemplateSpec(&in.Template, &out.Template, s); err != nil {
- return err
- }
- if in.VolumeClaimTemplates != nil {
- in, out := &in.VolumeClaimTemplates, &out.VolumeClaimTemplates
- *out = make([]api.PersistentVolumeClaim, len(*in))
- for i := range *in {
- if err := s.Convert(&(*in)[i], &(*out)[i], 0); err != nil {
- return err
- }
- }
- } else {
- out.VolumeClaimTemplates = nil
- }
- if err := Convert_v1beta2_StatefulSetUpdateStrategy_To_apps_StatefulSetUpdateStrategy(&in.UpdateStrategy, &out.UpdateStrategy, s); err != nil {
- return err
- }
- if in.RevisionHistoryLimit != nil {
- out.RevisionHistoryLimit = new(int32)
- *out.RevisionHistoryLimit = *in.RevisionHistoryLimit
- } else {
- out.RevisionHistoryLimit = nil
- }
- out.ServiceName = in.ServiceName
- out.PodManagementPolicy = apps.PodManagementPolicyType(in.PodManagementPolicy)
- return nil
- }
- func Convert_apps_StatefulSetSpec_To_v1beta2_StatefulSetSpec(in *apps.StatefulSetSpec, out *appsv1beta2.StatefulSetSpec, s conversion.Scope) error {
- out.Replicas = new(int32)
- *out.Replicas = in.Replicas
- if in.Selector != nil {
- in, out := &in.Selector, &out.Selector
- *out = new(metav1.LabelSelector)
- if err := s.Convert(*in, *out, 0); err != nil {
- return err
- }
- } else {
- out.Selector = nil
- }
- if err := k8s_api_v1.Convert_core_PodTemplateSpec_To_v1_PodTemplateSpec(&in.Template, &out.Template, s); err != nil {
- return err
- }
- if in.VolumeClaimTemplates != nil {
- in, out := &in.VolumeClaimTemplates, &out.VolumeClaimTemplates
- *out = make([]v1.PersistentVolumeClaim, len(*in))
- for i := range *in {
- if err := s.Convert(&(*in)[i], &(*out)[i], 0); err != nil {
- return err
- }
- }
- } else {
- out.VolumeClaimTemplates = nil
- }
- if in.RevisionHistoryLimit != nil {
- out.RevisionHistoryLimit = new(int32)
- *out.RevisionHistoryLimit = *in.RevisionHistoryLimit
- } else {
- out.RevisionHistoryLimit = nil
- }
- out.ServiceName = in.ServiceName
- out.PodManagementPolicy = appsv1beta2.PodManagementPolicyType(in.PodManagementPolicy)
- if err := Convert_apps_StatefulSetUpdateStrategy_To_v1beta2_StatefulSetUpdateStrategy(&in.UpdateStrategy, &out.UpdateStrategy, s); err != nil {
- return err
- }
- return nil
- }
- func Convert_v1beta2_StatefulSetUpdateStrategy_To_apps_StatefulSetUpdateStrategy(in *appsv1beta2.StatefulSetUpdateStrategy, out *apps.StatefulSetUpdateStrategy, s conversion.Scope) error {
- out.Type = apps.StatefulSetUpdateStrategyType(in.Type)
- if in.RollingUpdate != nil {
- out.RollingUpdate = new(apps.RollingUpdateStatefulSetStrategy)
- out.RollingUpdate.Partition = *in.RollingUpdate.Partition
- } else {
- out.RollingUpdate = nil
- }
- return nil
- }
- func Convert_apps_StatefulSetUpdateStrategy_To_v1beta2_StatefulSetUpdateStrategy(in *apps.StatefulSetUpdateStrategy, out *appsv1beta2.StatefulSetUpdateStrategy, s conversion.Scope) error {
- out.Type = appsv1beta2.StatefulSetUpdateStrategyType(in.Type)
- if in.RollingUpdate != nil {
- out.RollingUpdate = new(appsv1beta2.RollingUpdateStatefulSetStrategy)
- out.RollingUpdate.Partition = new(int32)
- *out.RollingUpdate.Partition = in.RollingUpdate.Partition
- } else {
- out.RollingUpdate = nil
- }
- return nil
- }
- func Convert_v1beta2_StatefulSetStatus_To_apps_StatefulSetStatus(in *appsv1beta2.StatefulSetStatus, out *apps.StatefulSetStatus, s conversion.Scope) error {
- out.ObservedGeneration = new(int64)
- *out.ObservedGeneration = in.ObservedGeneration
- out.Replicas = in.Replicas
- out.ReadyReplicas = in.ReadyReplicas
- out.CurrentReplicas = in.CurrentReplicas
- out.UpdatedReplicas = in.UpdatedReplicas
- out.CurrentRevision = in.CurrentRevision
- out.UpdateRevision = in.UpdateRevision
- if in.CollisionCount != nil {
- out.CollisionCount = new(int32)
- *out.CollisionCount = *in.CollisionCount
- }
- out.Conditions = make([]apps.StatefulSetCondition, len(in.Conditions))
- for i := range in.Conditions {
- if err := Convert_v1beta2_StatefulSetCondition_To_apps_StatefulSetCondition(&in.Conditions[i], &out.Conditions[i], s); err != nil {
- return err
- }
- }
- return nil
- }
- func Convert_apps_StatefulSetStatus_To_v1beta2_StatefulSetStatus(in *apps.StatefulSetStatus, out *appsv1beta2.StatefulSetStatus, s conversion.Scope) error {
- if in.ObservedGeneration != nil {
- out.ObservedGeneration = *in.ObservedGeneration
- }
- out.Replicas = in.Replicas
- out.ReadyReplicas = in.ReadyReplicas
- out.CurrentReplicas = in.CurrentReplicas
- out.UpdatedReplicas = in.UpdatedReplicas
- out.CurrentRevision = in.CurrentRevision
- out.UpdateRevision = in.UpdateRevision
- if in.CollisionCount != nil {
- out.CollisionCount = new(int32)
- *out.CollisionCount = *in.CollisionCount
- }
- out.Conditions = make([]appsv1beta2.StatefulSetCondition, len(in.Conditions))
- for i := range in.Conditions {
- if err := Convert_apps_StatefulSetCondition_To_v1beta2_StatefulSetCondition(&in.Conditions[i], &out.Conditions[i], s); err != nil {
- return err
- }
- }
- return nil
- }
- func Convert_autoscaling_ScaleStatus_To_v1beta2_ScaleStatus(in *autoscaling.ScaleStatus, out *appsv1beta2.ScaleStatus, s conversion.Scope) error {
- out.Replicas = int32(in.Replicas)
- out.TargetSelector = in.Selector
- out.Selector = nil
- selector, err := metav1.ParseToLabelSelector(in.Selector)
- if err != nil {
- return fmt.Errorf("failed to parse selector: %v", err)
- }
- if len(selector.MatchExpressions) == 0 {
- out.Selector = selector.MatchLabels
- }
- return nil
- }
- func Convert_v1beta2_ScaleStatus_To_autoscaling_ScaleStatus(in *appsv1beta2.ScaleStatus, out *autoscaling.ScaleStatus, s conversion.Scope) error {
- out.Replicas = in.Replicas
- // Normally when 2 fields map to the same internal value we favor the old field, since
- // old clients can't be expected to know about new fields but clients that know about the
- // new field can be expected to know about the old field (though that's not quite true, due
- // to kubectl apply). However, these fields are readonly, so any non-nil value should work.
- if in.TargetSelector != "" {
- out.Selector = in.TargetSelector
- } else if in.Selector != nil {
- set := labels.Set{}
- for key, val := range in.Selector {
- set[key] = val
- }
- out.Selector = labels.SelectorFromSet(set).String()
- } else {
- out.Selector = ""
- }
- return nil
- }
- func Convert_v1beta2_DeploymentSpec_To_apps_DeploymentSpec(in *appsv1beta2.DeploymentSpec, out *apps.DeploymentSpec, s conversion.Scope) error {
- if in.Replicas != nil {
- out.Replicas = *in.Replicas
- }
- out.Selector = in.Selector
- if err := k8s_api_v1.Convert_v1_PodTemplateSpec_To_core_PodTemplateSpec(&in.Template, &out.Template, s); err != nil {
- return err
- }
- if err := Convert_v1beta2_DeploymentStrategy_To_apps_DeploymentStrategy(&in.Strategy, &out.Strategy, s); err != nil {
- return err
- }
- out.RevisionHistoryLimit = in.RevisionHistoryLimit
- out.MinReadySeconds = in.MinReadySeconds
- out.Paused = in.Paused
- if in.ProgressDeadlineSeconds != nil {
- out.ProgressDeadlineSeconds = new(int32)
- *out.ProgressDeadlineSeconds = *in.ProgressDeadlineSeconds
- }
- return nil
- }
- func Convert_apps_DeploymentSpec_To_v1beta2_DeploymentSpec(in *apps.DeploymentSpec, out *appsv1beta2.DeploymentSpec, s conversion.Scope) error {
- out.Replicas = &in.Replicas
- out.Selector = in.Selector
- if err := k8s_api_v1.Convert_core_PodTemplateSpec_To_v1_PodTemplateSpec(&in.Template, &out.Template, s); err != nil {
- return err
- }
- if err := Convert_apps_DeploymentStrategy_To_v1beta2_DeploymentStrategy(&in.Strategy, &out.Strategy, s); err != nil {
- return err
- }
- if in.RevisionHistoryLimit != nil {
- out.RevisionHistoryLimit = new(int32)
- *out.RevisionHistoryLimit = int32(*in.RevisionHistoryLimit)
- }
- out.MinReadySeconds = int32(in.MinReadySeconds)
- out.Paused = in.Paused
- if in.ProgressDeadlineSeconds != nil {
- out.ProgressDeadlineSeconds = new(int32)
- *out.ProgressDeadlineSeconds = *in.ProgressDeadlineSeconds
- }
- return nil
- }
- func Convert_apps_DeploymentStrategy_To_v1beta2_DeploymentStrategy(in *apps.DeploymentStrategy, out *appsv1beta2.DeploymentStrategy, s conversion.Scope) error {
- out.Type = appsv1beta2.DeploymentStrategyType(in.Type)
- if in.RollingUpdate != nil {
- out.RollingUpdate = new(appsv1beta2.RollingUpdateDeployment)
- if err := Convert_apps_RollingUpdateDeployment_To_v1beta2_RollingUpdateDeployment(in.RollingUpdate, out.RollingUpdate, s); err != nil {
- return err
- }
- } else {
- out.RollingUpdate = nil
- }
- return nil
- }
- func Convert_v1beta2_DeploymentStrategy_To_apps_DeploymentStrategy(in *appsv1beta2.DeploymentStrategy, out *apps.DeploymentStrategy, s conversion.Scope) error {
- out.Type = apps.DeploymentStrategyType(in.Type)
- if in.RollingUpdate != nil {
- out.RollingUpdate = new(apps.RollingUpdateDeployment)
- if err := Convert_v1beta2_RollingUpdateDeployment_To_apps_RollingUpdateDeployment(in.RollingUpdate, out.RollingUpdate, s); err != nil {
- return err
- }
- } else {
- out.RollingUpdate = nil
- }
- return nil
- }
- func Convert_v1beta2_RollingUpdateDeployment_To_apps_RollingUpdateDeployment(in *appsv1beta2.RollingUpdateDeployment, out *apps.RollingUpdateDeployment, s conversion.Scope) error {
- if err := s.Convert(in.MaxUnavailable, &out.MaxUnavailable, 0); err != nil {
- return err
- }
- if err := s.Convert(in.MaxSurge, &out.MaxSurge, 0); err != nil {
- return err
- }
- return nil
- }
- func Convert_apps_RollingUpdateDeployment_To_v1beta2_RollingUpdateDeployment(in *apps.RollingUpdateDeployment, out *appsv1beta2.RollingUpdateDeployment, s conversion.Scope) error {
- if out.MaxUnavailable == nil {
- out.MaxUnavailable = &intstr.IntOrString{}
- }
- if err := s.Convert(&in.MaxUnavailable, out.MaxUnavailable, 0); err != nil {
- return err
- }
- if out.MaxSurge == nil {
- out.MaxSurge = &intstr.IntOrString{}
- }
- if err := s.Convert(&in.MaxSurge, out.MaxSurge, 0); err != nil {
- return err
- }
- return nil
- }
- func Convert_apps_ReplicaSetSpec_To_v1beta2_ReplicaSetSpec(in *apps.ReplicaSetSpec, out *appsv1beta2.ReplicaSetSpec, s conversion.Scope) error {
- out.Replicas = new(int32)
- *out.Replicas = int32(in.Replicas)
- out.MinReadySeconds = in.MinReadySeconds
- out.Selector = in.Selector
- if err := k8s_api_v1.Convert_core_PodTemplateSpec_To_v1_PodTemplateSpec(&in.Template, &out.Template, s); err != nil {
- return err
- }
- return nil
- }
- func Convert_v1beta2_Deployment_To_apps_Deployment(in *appsv1beta2.Deployment, out *apps.Deployment, s conversion.Scope) error {
- out.ObjectMeta = in.ObjectMeta
- if err := Convert_v1beta2_DeploymentSpec_To_apps_DeploymentSpec(&in.Spec, &out.Spec, s); err != nil {
- return err
- }
- // Copy annotation to deprecated rollbackTo field for roundtrip
- // TODO: remove this conversion after we delete extensions/v1beta1 and apps/v1beta1 Deployment
- if revision := in.Annotations[appsv1beta2.DeprecatedRollbackTo]; revision != "" {
- if revision64, err := strconv.ParseInt(revision, 10, 64); err != nil {
- return fmt.Errorf("failed to parse annotation[%s]=%s as int64: %v", appsv1beta2.DeprecatedRollbackTo, revision, err)
- } else {
- out.Spec.RollbackTo = new(apps.RollbackConfig)
- out.Spec.RollbackTo.Revision = revision64
- }
- out.Annotations = deepCopyStringMap(out.Annotations)
- delete(out.Annotations, appsv1beta2.DeprecatedRollbackTo)
- } else {
- out.Spec.RollbackTo = nil
- }
- if err := Convert_v1beta2_DeploymentStatus_To_apps_DeploymentStatus(&in.Status, &out.Status, s); err != nil {
- return err
- }
- return nil
- }
- func Convert_v1beta2_ReplicaSetSpec_To_apps_ReplicaSetSpec(in *appsv1beta2.ReplicaSetSpec, out *apps.ReplicaSetSpec, s conversion.Scope) error {
- if in.Replicas != nil {
- out.Replicas = *in.Replicas
- }
- out.MinReadySeconds = in.MinReadySeconds
- out.Selector = in.Selector
- if err := k8s_api_v1.Convert_v1_PodTemplateSpec_To_core_PodTemplateSpec(&in.Template, &out.Template, s); err != nil {
- return err
- }
- return nil
- }
- func Convert_apps_Deployment_To_v1beta2_Deployment(in *apps.Deployment, out *appsv1beta2.Deployment, s conversion.Scope) error {
- out.ObjectMeta = in.ObjectMeta
- out.Annotations = deepCopyStringMap(out.Annotations) // deep copy because we modify annotations below
- if err := Convert_apps_DeploymentSpec_To_v1beta2_DeploymentSpec(&in.Spec, &out.Spec, s); err != nil {
- return err
- }
- // Copy deprecated rollbackTo field to annotation for roundtrip
- // TODO: remove this conversion after we delete extensions/v1beta1 and apps/v1beta1 Deployment
- if in.Spec.RollbackTo != nil {
- if out.Annotations == nil {
- out.Annotations = make(map[string]string)
- }
- out.Annotations[appsv1beta2.DeprecatedRollbackTo] = strconv.FormatInt(in.Spec.RollbackTo.Revision, 10)
- } else {
- delete(out.Annotations, appsv1beta2.DeprecatedRollbackTo)
- }
- if err := Convert_apps_DeploymentStatus_To_v1beta2_DeploymentStatus(&in.Status, &out.Status, s); err != nil {
- return err
- }
- return nil
- }
- func Convert_apps_DaemonSet_To_v1beta2_DaemonSet(in *apps.DaemonSet, out *appsv1beta2.DaemonSet, s conversion.Scope) error {
- out.ObjectMeta = in.ObjectMeta
- out.Annotations = deepCopyStringMap(out.Annotations)
- out.Annotations[appsv1beta2.DeprecatedTemplateGeneration] = strconv.FormatInt(in.Spec.TemplateGeneration, 10)
- if err := Convert_apps_DaemonSetSpec_To_v1beta2_DaemonSetSpec(&in.Spec, &out.Spec, s); err != nil {
- return err
- }
- if err := s.Convert(&in.Status, &out.Status, 0); err != nil {
- return err
- }
- return nil
- }
- func Convert_apps_DaemonSetSpec_To_v1beta2_DaemonSetSpec(in *apps.DaemonSetSpec, out *appsv1beta2.DaemonSetSpec, s conversion.Scope) error {
- out.Selector = in.Selector
- if err := k8s_api_v1.Convert_core_PodTemplateSpec_To_v1_PodTemplateSpec(&in.Template, &out.Template, s); err != nil {
- return err
- }
- if err := Convert_apps_DaemonSetUpdateStrategy_To_v1beta2_DaemonSetUpdateStrategy(&in.UpdateStrategy, &out.UpdateStrategy, s); err != nil {
- return err
- }
- out.MinReadySeconds = int32(in.MinReadySeconds)
- if in.RevisionHistoryLimit != nil {
- out.RevisionHistoryLimit = new(int32)
- *out.RevisionHistoryLimit = *in.RevisionHistoryLimit
- } else {
- out.RevisionHistoryLimit = nil
- }
- return nil
- }
- func Convert_apps_DaemonSetUpdateStrategy_To_v1beta2_DaemonSetUpdateStrategy(in *apps.DaemonSetUpdateStrategy, out *appsv1beta2.DaemonSetUpdateStrategy, s conversion.Scope) error {
- out.Type = appsv1beta2.DaemonSetUpdateStrategyType(in.Type)
- if in.RollingUpdate != nil {
- out.RollingUpdate = &appsv1beta2.RollingUpdateDaemonSet{}
- if err := Convert_apps_RollingUpdateDaemonSet_To_v1beta2_RollingUpdateDaemonSet(in.RollingUpdate, out.RollingUpdate, s); err != nil {
- return err
- }
- }
- return nil
- }
- func Convert_v1beta2_DaemonSet_To_apps_DaemonSet(in *appsv1beta2.DaemonSet, out *apps.DaemonSet, s conversion.Scope) error {
- out.ObjectMeta = in.ObjectMeta
- if err := Convert_v1beta2_DaemonSetSpec_To_apps_DaemonSetSpec(&in.Spec, &out.Spec, s); err != nil {
- return err
- }
- if value, ok := in.Annotations[appsv1beta2.DeprecatedTemplateGeneration]; ok {
- if value64, err := strconv.ParseInt(value, 10, 64); err != nil {
- return err
- } else {
- out.Spec.TemplateGeneration = value64
- out.Annotations = deepCopyStringMap(out.Annotations)
- delete(out.Annotations, appsv1beta2.DeprecatedTemplateGeneration)
- }
- }
- if err := s.Convert(&in.Status, &out.Status, 0); err != nil {
- return err
- }
- return nil
- }
- func Convert_v1beta2_DaemonSetSpec_To_apps_DaemonSetSpec(in *appsv1beta2.DaemonSetSpec, out *apps.DaemonSetSpec, s conversion.Scope) error {
- out.Selector = in.Selector
- if err := k8s_api_v1.Convert_v1_PodTemplateSpec_To_core_PodTemplateSpec(&in.Template, &out.Template, s); err != nil {
- return err
- }
- if err := Convert_v1beta2_DaemonSetUpdateStrategy_To_apps_DaemonSetUpdateStrategy(&in.UpdateStrategy, &out.UpdateStrategy, s); err != nil {
- return err
- }
- if in.RevisionHistoryLimit != nil {
- out.RevisionHistoryLimit = new(int32)
- *out.RevisionHistoryLimit = *in.RevisionHistoryLimit
- } else {
- out.RevisionHistoryLimit = nil
- }
- out.MinReadySeconds = in.MinReadySeconds
- return nil
- }
- func Convert_v1beta2_DaemonSetUpdateStrategy_To_apps_DaemonSetUpdateStrategy(in *appsv1beta2.DaemonSetUpdateStrategy, out *apps.DaemonSetUpdateStrategy, s conversion.Scope) error {
- out.Type = apps.DaemonSetUpdateStrategyType(in.Type)
- if in.RollingUpdate != nil {
- out.RollingUpdate = &apps.RollingUpdateDaemonSet{}
- if err := Convert_v1beta2_RollingUpdateDaemonSet_To_apps_RollingUpdateDaemonSet(in.RollingUpdate, out.RollingUpdate, s); err != nil {
- return err
- }
- }
- return nil
- }
- func deepCopyStringMap(m map[string]string) map[string]string {
- ret := make(map[string]string, len(m))
- for k, v := range m {
- ret[k] = v
- }
- return ret
- }
|