diff options
Diffstat (limited to 'tests/performance/nodedensity/nodedensity_suite_test.go')
| -rw-r--r-- | tests/performance/nodedensity/nodedensity_suite_test.go | 104 |
1 files changed, 0 insertions, 104 deletions
diff --git a/tests/performance/nodedensity/nodedensity_suite_test.go b/tests/performance/nodedensity/nodedensity_suite_test.go deleted file mode 100644 index 8cc47fdc9..000000000 --- a/tests/performance/nodedensity/nodedensity_suite_test.go +++ /dev/null @@ -1,104 +0,0 @@ -/* -Copyright 2019 The KubeEdge 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 nodedensity - -import ( - "net" - "net/url" - "strconv" - "strings" - "testing" - "time" - - . "github.com/onsi/ginkgo" - . "github.com/onsi/gomega" - metav1 "k8s.io/api/core/v1" - - "github.com/kubeedge/kubeedge/tests/e2e/utils" - . "github.com/kubeedge/kubeedge/tests/performance/common" - "github.com/kubeedge/viaduct/pkg/api" -) - -//context to load config and access across the package -var ( - ctx *utils.TestContext - cfg utils.Config - cloudHubURL string - wsscloudHubURL string - quiccloudHubURL string -) - -func TestEdgecoreK8sDeployment(t *testing.T) { - var cloudCoreHostIP string - var podlist metav1.PodList - //var toTaint bool - RegisterFailHandler(Fail) - var _ = BeforeSuite(func() { - utils.Infof("Kubeedge deployment Load test Begin !!") - cfg = utils.LoadConfig() - ctx = utils.NewTestContext(cfg) - //apply label to all cluster nodes, use the selector to deploy all edgenodes to cluster nodes - err := ApplyLabel(ctx.Cfg.K8SMasterForProvisionEdgeNodes + NodeHandler) - Expect(err).Should(BeNil()) - //Create configMap for CloudCore - CloudConfigMap = "cloudcore-configmap-" + utils.GetRandomString(5) - CloudCoreDeployment = "cloudcore-deployment-" + utils.GetRandomString(5) - //protocol to be used for test between edge and cloud - if ctx.Cfg.Protocol == api.ProtocolTypeQuic { - IsQuicProtocol = true - } else { - IsQuicProtocol = false - } - //Deploye cloudcore as a k8s resource to cluster-1 - err = HandleCloudDeployment(CloudConfigMap, CloudCoreDeployment, ctx.Cfg.K8SMasterForKubeEdge, - ctx.Cfg.K8SMasterForKubeEdge+ConfigmapHandler, ctx.Cfg.K8SMasterForKubeEdge+DeploymentHandler, ctx.Cfg.CloudImageURL, ctx.Cfg.NumOfNodes) - Expect(err).Should(BeNil()) - time.Sleep(1 * time.Second) - //Get the cloudCore pod Node name and IP - podlist, err = utils.GetPods(ctx.Cfg.K8SMasterForKubeEdge+AppHandler, "") - Expect(err).To(BeNil()) - for _, pod := range podlist.Items { - if strings.Contains(pod.Name, "cloudcore-deployment") { - cloudCoreHostIP = pod.Status.HostIP - break - } - } - utils.CheckPodRunningState(ctx.Cfg.K8SMasterForKubeEdge+AppHandler, podlist) - time.Sleep(300 * time.Second) - //Create service for cloud - err = utils.ExposeCloudService(CloudCoreDeployment, ctx.Cfg.K8SMasterForKubeEdge+ServiceHandler) - Expect(err).Should(BeNil()) - //Create a nodePort Service to access the cloud Service from the cluster nodes - wsPort, quicPort := utils.GetServicePort(CloudCoreDeployment, ctx.Cfg.K8SMasterForKubeEdge+ServiceHandler) - wsNodePort := strconv.FormatInt(int64(wsPort), 10) - quicNodePort := strconv.FormatInt(int64(quicPort), 10) - quiccloudHubURL = net.JoinHostPort(cloudCoreHostIP, quicNodePort) - cloudHubURL = quiccloudHubURL - wsscloudHubURL = (&url.URL{ - Scheme: "wss", - Host: net.JoinHostPort(cloudCoreHostIP, wsNodePort), - }).String() - cloudHubURL = wsscloudHubURL - }) - AfterSuite(func() { - By("Kubeedge deployment Load test End !!....!") - - DeleteCloudDeployment(ctx.Cfg.K8SMasterForKubeEdge) - utils.CheckPodDeleteState(ctx.Cfg.K8SMasterForKubeEdge+AppHandler, podlist) - }) - - RunSpecs(t, "kubeedge Performance Load test Suite") -} |
