...
1
16
17 package apps
18
19 import (
20 "context"
21
22 "k8s.io/kubernetes/test/e2e/cloud/gcp/common"
23 "k8s.io/kubernetes/test/e2e/feature"
24 "k8s.io/kubernetes/test/e2e/framework"
25 e2epv "k8s.io/kubernetes/test/e2e/framework/pv"
26 "k8s.io/kubernetes/test/e2e/upgrades"
27 "k8s.io/kubernetes/test/e2e/upgrades/apps"
28 "k8s.io/kubernetes/test/utils/junit"
29 admissionapi "k8s.io/pod-security-admission/api"
30
31 "github.com/onsi/ginkgo/v2"
32 )
33
34 var upgradeTests = []upgrades.Test{
35 &apps.MySQLUpgradeTest{},
36 &apps.EtcdUpgradeTest{},
37 &apps.CassandraUpgradeTest{},
38 }
39
40 var _ = SIGDescribe("stateful Upgrade", feature.StatefulUpgrade, func() {
41 f := framework.NewDefaultFramework("stateful-upgrade")
42 f.NamespacePodSecurityLevel = admissionapi.LevelPrivileged
43 testFrameworks := upgrades.CreateUpgradeFrameworks(upgradeTests)
44
45 ginkgo.Describe("stateful upgrade", func() {
46 ginkgo.It("should maintain a functioning cluster", func(ctx context.Context) {
47 e2epv.SkipIfNoDefaultStorageClass(ctx, f.ClientSet)
48 upgCtx, err := common.GetUpgradeContext(f.ClientSet.Discovery())
49 framework.ExpectNoError(err)
50
51 testSuite := &junit.TestSuite{Name: "Stateful upgrade"}
52 statefulUpgradeTest := &junit.TestCase{Name: "[sig-apps] stateful-upgrade", Classname: "upgrade_tests"}
53 testSuite.TestCases = append(testSuite.TestCases, statefulUpgradeTest)
54
55 upgradeFunc := common.ClusterUpgradeFunc(f, upgCtx, statefulUpgradeTest, nil, nil)
56 upgrades.RunUpgradeSuite(ctx, upgCtx, upgradeTests, testFrameworks, testSuite, upgrades.ClusterUpgrade, upgradeFunc)
57 })
58 })
59 })
60
View as plain text