Skip to content

Commit c318482

Browse files
authored
Merge pull request kubernetes#85556 from wojtek-t/fix_kubectl_conversions
Cleanup conversions in kubectl
2 parents e6b0dbb + bfa4188 commit c318482

File tree

3 files changed

+12
-10
lines changed

3 files changed

+12
-10
lines changed

staging/src/k8s.io/kubectl/pkg/polymorphichelpers/BUILD

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,6 @@ go_test(
9797
"//staging/src/k8s.io/apimachinery/pkg/watch:go_default_library",
9898
"//staging/src/k8s.io/client-go/kubernetes/fake:go_default_library",
9999
"//staging/src/k8s.io/client-go/testing:go_default_library",
100-
"//staging/src/k8s.io/kubectl/pkg/scheme:go_default_library",
101100
"//staging/src/k8s.io/kubectl/pkg/util/podutils:go_default_library",
102101
],
103102
)

staging/src/k8s.io/kubectl/pkg/polymorphichelpers/rollout_status.go

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@ import (
2323
extensionsv1beta1 "k8s.io/api/extensions/v1beta1"
2424
"k8s.io/apimachinery/pkg/runtime"
2525
"k8s.io/apimachinery/pkg/runtime/schema"
26-
"k8s.io/kubectl/pkg/scheme"
2726
deploymentutil "k8s.io/kubectl/pkg/util/deployment"
2827
)
2928

@@ -59,7 +58,7 @@ type StatefulSetStatusViewer struct{}
5958
// Status returns a message describing deployment status, and a bool value indicating if the status is considered done.
6059
func (s *DeploymentStatusViewer) Status(obj runtime.Unstructured, revision int64) (string, bool, error) {
6160
deployment := &appsv1.Deployment{}
62-
err := scheme.Scheme.Convert(obj, deployment, nil)
61+
err := runtime.DefaultUnstructuredConverter.FromUnstructured(obj.UnstructuredContent(), deployment)
6362
if err != nil {
6463
return "", false, fmt.Errorf("failed to convert %T to %T: %v", obj, deployment, err)
6564
}
@@ -97,7 +96,7 @@ func (s *DaemonSetStatusViewer) Status(obj runtime.Unstructured, revision int64)
9796
//ignoring revision as DaemonSets does not have history yet
9897

9998
daemon := &appsv1.DaemonSet{}
100-
err := scheme.Scheme.Convert(obj, daemon, nil)
99+
err := runtime.DefaultUnstructuredConverter.FromUnstructured(obj.UnstructuredContent(), daemon)
101100
if err != nil {
102101
return "", false, fmt.Errorf("failed to convert %T to %T: %v", obj, daemon, err)
103102
}
@@ -120,7 +119,7 @@ func (s *DaemonSetStatusViewer) Status(obj runtime.Unstructured, revision int64)
120119
// Status returns a message describing statefulset status, and a bool value indicating if the status is considered done.
121120
func (s *StatefulSetStatusViewer) Status(obj runtime.Unstructured, revision int64) (string, bool, error) {
122121
sts := &appsv1.StatefulSet{}
123-
err := scheme.Scheme.Convert(obj, sts, nil)
122+
err := runtime.DefaultUnstructuredConverter.FromUnstructured(obj.UnstructuredContent(), sts)
124123
if err != nil {
125124
return "", false, fmt.Errorf("failed to convert %T to %T: %v", obj, sts, err)
126125
}

staging/src/k8s.io/kubectl/pkg/polymorphichelpers/rollout_status_test.go

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ import (
2424
api "k8s.io/api/core/v1"
2525
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
2626
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
27-
"k8s.io/kubectl/pkg/scheme"
27+
"k8s.io/apimachinery/pkg/runtime"
2828
)
2929

3030
func TestDeploymentStatusViewerStatus(t *testing.T) {
@@ -128,7 +128,8 @@ func TestDeploymentStatusViewerStatus(t *testing.T) {
128128
Status: test.status,
129129
}
130130
unstructuredD := &unstructured.Unstructured{}
131-
err := scheme.Scheme.Convert(d, unstructuredD, nil)
131+
var err error
132+
unstructuredD.Object, err = runtime.DefaultUnstructuredConverter.ToUnstructured(d)
132133
if err != nil {
133134
t.Fatal(err)
134135
}
@@ -233,7 +234,8 @@ func TestDaemonSetStatusViewerStatus(t *testing.T) {
233234
}
234235

235236
unstructuredD := &unstructured.Unstructured{}
236-
err := scheme.Scheme.Convert(d, unstructuredD, nil)
237+
var err error
238+
unstructuredD.Object, err = runtime.DefaultUnstructuredConverter.ToUnstructured(d)
237239
if err != nil {
238240
t.Fatal(err)
239241
}
@@ -384,7 +386,8 @@ func TestStatefulSetStatusViewerStatus(t *testing.T) {
384386
s.Generation = test.generation
385387

386388
unstructuredS := &unstructured.Unstructured{}
387-
err := scheme.Scheme.Convert(s, unstructuredS, nil)
389+
var err error
390+
unstructuredS.Object, err = runtime.DefaultUnstructuredConverter.ToUnstructured(s)
388391
if err != nil {
389392
t.Fatal(err)
390393
}
@@ -422,7 +425,8 @@ func TestDaemonSetStatusViewerStatusWithWrongUpdateStrategyType(t *testing.T) {
422425
}
423426

424427
unstructuredD := &unstructured.Unstructured{}
425-
err := scheme.Scheme.Convert(d, unstructuredD, nil)
428+
var err error
429+
unstructuredD.Object, err = runtime.DefaultUnstructuredConverter.ToUnstructured(d)
426430
if err != nil {
427431
t.Fatal(err)
428432
}

0 commit comments

Comments
 (0)