From de370721d3d2ab0028d598c9fa5f21e0d5270675 Mon Sep 17 00:00:00 2001 From: Sedef Date: Wed, 25 Mar 2020 07:35:35 -0700 Subject: [PATCH] [e2e] add kube-proxy version check --- test/infrastructure/docker/e2e/docker_test.go | 20 +++++++++++++++++-- 1 file changed, 18 insertions(+), 2 deletions(-) diff --git a/test/infrastructure/docker/e2e/docker_test.go b/test/infrastructure/docker/e2e/docker_test.go index 8a69ffc8cff2..2315ec0f200c 100644 --- a/test/infrastructure/docker/e2e/docker_test.go +++ b/test/infrastructure/docker/e2e/docker_test.go @@ -26,8 +26,9 @@ import ( . "github.com/onsi/ginkgo" . "github.com/onsi/gomega" - "k8s.io/apimachinery/pkg/runtime" + "k8s.io/apimachinery/pkg/runtime" + appsv1 "k8s.io/api/apps/v1" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" clusterv1 "sigs.k8s.io/cluster-api/api/v1alpha3" @@ -49,6 +50,7 @@ var _ = Describe("Docker", func() { var ( namespace string clusterGen = &ClusterGenerator{} + workloadClient ctrlclient.Client ) SetDefaultEventuallyTimeout(3 * time.Minute) SetDefaultEventuallyPollingInterval(10 * time.Second) @@ -125,7 +127,7 @@ var _ = Describe("Docker", func() { framework.WaitForOneKubeadmControlPlaneMachineToExist(ctx, waitForOneKubeadmControlPlaneMachineToExistInput, "5m") // Insatll a networking solution on the workload cluster - workloadClient, err := mgmt.GetWorkloadClient(ctx, cluster.Namespace, cluster.Name) + workloadClient, err = mgmt.GetWorkloadClient(ctx, cluster.Namespace, cluster.Name) Expect(err).ToNot(HaveOccurred()) applyYAMLURLInput := framework.ApplyYAMLURLInput{ Client: workloadClient, @@ -213,6 +215,20 @@ var _ = Describe("Docker", func() { } return upgraded, nil }, "10m", "30s").Should(Equal(int(*controlPlane.Spec.Replicas))) + + Eventually(func() (bool, error) { + ds := &appsv1.DaemonSet{} + + if err := workloadClient.Get(ctx, ctrlclient.ObjectKey{Name: "kube-proxy", Namespace: metav1.NamespaceSystem}, ds); err != nil { + return false, err + } + if ds.Spec.Template.Spec.Containers[0].Image == "k8s.gcr.io/kube-proxy:v1.17.2" { + return true, nil + } + + return false, nil + }, "10m", "30s").Should(BeTrue()) + }) }) })