github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-29 06:27:05 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #85556 from wojtek-t/fix_kubectl_conversions

Browse Source 
Cleanup conversions in kubectl
This commit is contained in:
Kubernetes Prow Robot 2019-11-25 09:04:01 -08:00 committed by GitHub
commit c3184828cb
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 12 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
staging/src/k8s.io/kubectl/pkg/polymorphichelpers/BUILD
View File

@ -97,7 +97,6 @@ go_test(
"//staging/src/k8s.io/apimachinery/pkg/watch:go_default_library",
"//staging/src/k8s.io/client-go/kubernetes/fake:go_default_library",
"//staging/src/k8s.io/client-go/testing:go_default_library",
"//staging/src/k8s.io/kubectl/pkg/scheme:go_default_library",
"//staging/src/k8s.io/kubectl/pkg/util/podutils:go_default_library",
],
)

7
staging/src/k8s.io/kubectl/pkg/polymorphichelpers/rollout_status.go
View File

@ -23,7 +23,6 @@ import (
extensionsv1beta1 "k8s.io/api/extensions/v1beta1"
"k8s.io/apimachinery/pkg/runtime"
"k8s.io/apimachinery/pkg/runtime/schema"
"k8s.io/kubectl/pkg/scheme"
deploymentutil "k8s.io/kubectl/pkg/util/deployment"
)
@ -59,7 +58,7 @@ type StatefulSetStatusViewer struct{}
// Status returns a message describing deployment status, and a bool value indicating if the status is considered done.
func (s *DeploymentStatusViewer) Status(obj runtime.Unstructured, revision int64) (string, bool, error) {
deployment := &appsv1.Deployment{}
err := scheme.Scheme.Convert(obj, deployment, nil)
err := runtime.DefaultUnstructuredConverter.FromUnstructured(obj.UnstructuredContent(), deployment)
if err != nil {
return "", false, fmt.Errorf("failed to convert %T to %T: %v", obj, deployment, err)
}
@ -97,7 +96,7 @@ func (s *DaemonSetStatusViewer) Status(obj runtime.Unstructured, revision int64)
//ignoring revision as DaemonSets does not have history yet
daemon := &appsv1.DaemonSet{}
err := scheme.Scheme.Convert(obj, daemon, nil)
err := runtime.DefaultUnstructuredConverter.FromUnstructured(obj.UnstructuredContent(), daemon)
if err != nil {
return "", false, fmt.Errorf("failed to convert %T to %T: %v", obj, daemon, err)
}
@ -120,7 +119,7 @@ func (s *DaemonSetStatusViewer) Status(obj runtime.Unstructured, revision int64)
// Status returns a message describing statefulset status, and a bool value indicating if the status is considered done.
func (s *StatefulSetStatusViewer) Status(obj runtime.Unstructured, revision int64) (string, bool, error) {
sts := &appsv1.StatefulSet{}
err := scheme.Scheme.Convert(obj, sts, nil)
err := runtime.DefaultUnstructuredConverter.FromUnstructured(obj.UnstructuredContent(), sts)
if err != nil {
return "", false, fmt.Errorf("failed to convert %T to %T: %v", obj, sts, err)
}

14
staging/src/k8s.io/kubectl/pkg/polymorphichelpers/rollout_status_test.go
View File

@ -24,7 +24,7 @@ import (
api "k8s.io/api/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
"k8s.io/kubectl/pkg/scheme"
"k8s.io/apimachinery/pkg/runtime"
)
func TestDeploymentStatusViewerStatus(t *testing.T) {
@ -128,7 +128,8 @@ func TestDeploymentStatusViewerStatus(t *testing.T) {
Status: test.status,
}
unstructuredD := &unstructured.Unstructured{}
err := scheme.Scheme.Convert(d, unstructuredD, nil)
var err error
unstructuredD.Object, err = runtime.DefaultUnstructuredConverter.ToUnstructured(d)
if err != nil {
t.Fatal(err)
}
@ -233,7 +234,8 @@ func TestDaemonSetStatusViewerStatus(t *testing.T) {
}
unstructuredD := &unstructured.Unstructured{}
err := scheme.Scheme.Convert(d, unstructuredD, nil)
var err error
unstructuredD.Object, err = runtime.DefaultUnstructuredConverter.ToUnstructured(d)
if err != nil {
t.Fatal(err)
}
@ -384,7 +386,8 @@ func TestStatefulSetStatusViewerStatus(t *testing.T) {
s.Generation = test.generation
unstructuredS := &unstructured.Unstructured{}
err := scheme.Scheme.Convert(s, unstructuredS, nil)
var err error
unstructuredS.Object, err = runtime.DefaultUnstructuredConverter.ToUnstructured(s)
if err != nil {
t.Fatal(err)
}
@ -422,7 +425,8 @@ func TestDaemonSetStatusViewerStatusWithWrongUpdateStrategyType(t *testing.T) {
}
unstructuredD := &unstructured.Unstructured{}
err := scheme.Scheme.Convert(d, unstructuredD, nil)
var err error
unstructuredD.Object, err = runtime.DefaultUnstructuredConverter.ToUnstructured(d)
if err != nil {
t.Fatal(err)
}