mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-09-14 13:45:06 +00:00
Merge pull request #37997 from foxish/dawn_pr
Automatic merge from submit-queue (batch tested with PRs 37997, 37939, 37990, 36700, 37258) Revert "Skip StatefulSet e2e tests if this resource is not found" Replaces https://github.com/kubernetes/kubernetes/pull/37398
This commit is contained in:
@@ -368,7 +368,6 @@ var _ = framework.KubeDescribe("Network Partition [Disruptive] [Slow]", func() {
|
|||||||
|
|
||||||
BeforeEach(func() {
|
BeforeEach(func() {
|
||||||
framework.SkipUnlessProviderIs("gce", "gke")
|
framework.SkipUnlessProviderIs("gce", "gke")
|
||||||
framework.SkipIfMissingResource(f.ClientPool, StatefulSetGroupVersionResource, f.Namespace.Name)
|
|
||||||
By("creating service " + headlessSvcName + " in namespace " + f.Namespace.Name)
|
By("creating service " + headlessSvcName + " in namespace " + f.Namespace.Name)
|
||||||
headlessService := createServiceSpec(headlessSvcName, "", true, labels)
|
headlessService := createServiceSpec(headlessSvcName, "", true, labels)
|
||||||
_, err := f.ClientSet.Core().Services(f.Namespace.Name).Create(headlessService)
|
_, err := f.ClientSet.Core().Services(f.Namespace.Name).Create(headlessService)
|
||||||
|
@@ -39,7 +39,6 @@ import (
|
|||||||
"k8s.io/kubernetes/pkg/labels"
|
"k8s.io/kubernetes/pkg/labels"
|
||||||
klabels "k8s.io/kubernetes/pkg/labels"
|
klabels "k8s.io/kubernetes/pkg/labels"
|
||||||
"k8s.io/kubernetes/pkg/runtime"
|
"k8s.io/kubernetes/pkg/runtime"
|
||||||
"k8s.io/kubernetes/pkg/runtime/schema"
|
|
||||||
"k8s.io/kubernetes/pkg/types"
|
"k8s.io/kubernetes/pkg/types"
|
||||||
"k8s.io/kubernetes/pkg/util/intstr"
|
"k8s.io/kubernetes/pkg/util/intstr"
|
||||||
"k8s.io/kubernetes/pkg/util/sets"
|
"k8s.io/kubernetes/pkg/util/sets"
|
||||||
@@ -66,10 +65,6 @@ const (
|
|||||||
readTimeout = 60 * time.Second
|
readTimeout = 60 * time.Second
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
|
||||||
StatefulSetGroupVersionResource = schema.GroupVersionResource{Group: apps.GroupName, Version: "v1beta1", Resource: "statefulsets"}
|
|
||||||
)
|
|
||||||
|
|
||||||
// GCE Quota requirements: 3 pds, one per pet manifest declared above.
|
// GCE Quota requirements: 3 pds, one per pet manifest declared above.
|
||||||
// GCE Api requirements: nodes and master need storage r/w permissions.
|
// GCE Api requirements: nodes and master need storage r/w permissions.
|
||||||
var _ = framework.KubeDescribe("StatefulSet", func() {
|
var _ = framework.KubeDescribe("StatefulSet", func() {
|
||||||
@@ -80,7 +75,6 @@ var _ = framework.KubeDescribe("StatefulSet", func() {
|
|||||||
BeforeEach(func() {
|
BeforeEach(func() {
|
||||||
c = f.ClientSet
|
c = f.ClientSet
|
||||||
ns = f.Namespace.Name
|
ns = f.Namespace.Name
|
||||||
framework.SkipIfMissingResource(f.ClientPool, StatefulSetGroupVersionResource, f.Namespace.Name)
|
|
||||||
})
|
})
|
||||||
|
|
||||||
framework.KubeDescribe("Basic StatefulSet functionality", func() {
|
framework.KubeDescribe("Basic StatefulSet functionality", func() {
|
||||||
@@ -408,7 +402,7 @@ var _ = framework.KubeDescribe("Stateful Set recreate", func() {
|
|||||||
petPodName := "web-0"
|
petPodName := "web-0"
|
||||||
|
|
||||||
BeforeEach(func() {
|
BeforeEach(func() {
|
||||||
framework.SkipIfMissingResource(f.ClientPool, StatefulSetGroupVersionResource, f.Namespace.Name)
|
framework.SkipUnlessProviderIs("gce", "gke", "vagrant")
|
||||||
By("creating service " + headlessSvcName + " in namespace " + f.Namespace.Name)
|
By("creating service " + headlessSvcName + " in namespace " + f.Namespace.Name)
|
||||||
headlessService := createServiceSpec(headlessSvcName, "", true, labels)
|
headlessService := createServiceSpec(headlessSvcName, "", true, labels)
|
||||||
_, err := f.ClientSet.Core().Services(f.Namespace.Name).Create(headlessService)
|
_, err := f.ClientSet.Core().Services(f.Namespace.Name).Create(headlessService)
|
||||||
|
Reference in New Issue
Block a user