From 69808b74ec777a009271722b12f07055f033be0d Mon Sep 17 00:00:00 2001 From: Matthew Cary Date: Tue, 7 Feb 2023 17:33:32 -0800 Subject: [PATCH] Remove obsolete GKE local SSD test Change-Id: I156bd03ac740c2ebe394081d3106851f7182269f --- test/e2e/storage/gke_local_ssd.go | 116 ------------------------------ 1 file changed, 116 deletions(-) delete mode 100644 test/e2e/storage/gke_local_ssd.go diff --git a/test/e2e/storage/gke_local_ssd.go b/test/e2e/storage/gke_local_ssd.go deleted file mode 100644 index 263f3c573cc..00000000000 --- a/test/e2e/storage/gke_local_ssd.go +++ /dev/null @@ -1,116 +0,0 @@ -/* -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 storage - -import ( - "context" - "fmt" - "os/exec" - - v1 "k8s.io/api/core/v1" - metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" - "k8s.io/apimachinery/pkg/util/uuid" - "k8s.io/kubernetes/test/e2e/framework" - e2eoutput "k8s.io/kubernetes/test/e2e/framework/pod/output" - e2eskipper "k8s.io/kubernetes/test/e2e/framework/skipper" - "k8s.io/kubernetes/test/e2e/storage/utils" - admissionapi "k8s.io/pod-security-admission/api" - - "github.com/onsi/ginkgo/v2" -) - -var _ = utils.SIGDescribe("GKE local SSD [Feature:GKELocalSSD]", func() { - - f := framework.NewDefaultFramework("localssd") - f.NamespacePodSecurityEnforceLevel = admissionapi.LevelPrivileged - - ginkgo.BeforeEach(func() { - e2eskipper.SkipUnlessProviderIs("gke") - }) - - ginkgo.It("should write and read from node local SSD [Feature:GKELocalSSD]", func(ctx context.Context) { - framework.Logf("Start local SSD test") - createNodePoolWithLocalSsds("np-ssd") - doTestWriteAndReadToLocalSsd(ctx, f) - }) -}) - -func createNodePoolWithLocalSsds(nodePoolName string) { - framework.Logf("Create node pool: %s with local SSDs in cluster: %s ", - nodePoolName, framework.TestContext.CloudConfig.Cluster) - out, err := exec.Command("gcloud", "alpha", "container", "node-pools", "create", - nodePoolName, - fmt.Sprintf("--cluster=%s", framework.TestContext.CloudConfig.Cluster), - "--local-ssd-count=1").CombinedOutput() - if err != nil { - framework.Failf("Failed to create node pool %s: Err: %v\n%v", nodePoolName, err, string(out)) - } - framework.Logf("Successfully created node pool %s:\n%v", nodePoolName, string(out)) -} - -func doTestWriteAndReadToLocalSsd(ctx context.Context, f *framework.Framework) { - var pod = testPodWithSsd("echo 'hello world' > /mnt/disks/ssd0/data && sleep 1 && cat /mnt/disks/ssd0/data") - var msg string - var out = []string{"hello world"} - - e2eoutput.TestContainerOutput(ctx, f, msg, pod, 0, out) -} - -func testPodWithSsd(command string) *v1.Pod { - containerName := "test-container" - volumeName := "test-ssd-volume" - path := "/mnt/disks/ssd0" - podName := "pod-" + string(uuid.NewUUID()) - image := "ubuntu:14.04" - return &v1.Pod{ - TypeMeta: metav1.TypeMeta{ - Kind: "Pod", - APIVersion: "v1", - }, - ObjectMeta: metav1.ObjectMeta{ - Name: podName, - }, - Spec: v1.PodSpec{ - Containers: []v1.Container{ - { - Name: containerName, - Image: image, - Command: []string{"/bin/sh"}, - Args: []string{"-c", command}, - VolumeMounts: []v1.VolumeMount{ - { - Name: volumeName, - MountPath: path, - }, - }, - }, - }, - RestartPolicy: v1.RestartPolicyNever, - Volumes: []v1.Volume{ - { - Name: volumeName, - VolumeSource: v1.VolumeSource{ - HostPath: &v1.HostPathVolumeSource{ - Path: path, - }, - }, - }, - }, - NodeSelector: map[string]string{"cloud.google.com/gke-local-ssd": "true"}, - }, - } -}