cap the num of nodes on the noSNAT test and remove slow and NoSNAT tag
run NoSNAT network test between pods without any feature tag
This commit is contained in:
		| @@ -254,10 +254,6 @@ var ( | |||||||
| 	// TODO: document the feature (owning SIG, when to use this feature for a test) | 	// TODO: document the feature (owning SIG, when to use this feature for a test) | ||||||
| 	NodeOutOfServiceVolumeDetach = framework.WithFeature(framework.ValidFeatures.Add("NodeOutOfServiceVolumeDetach")) | 	NodeOutOfServiceVolumeDetach = framework.WithFeature(framework.ValidFeatures.Add("NodeOutOfServiceVolumeDetach")) | ||||||
|  |  | ||||||
| 	// Owner: sig-network |  | ||||||
| 	// Marks a single test that tests pod-to-pod connectivity between every pair of nodes. |  | ||||||
| 	NoSNAT = framework.WithFeature(framework.ValidFeatures.Add("NoSNAT")) |  | ||||||
|  |  | ||||||
| 	// Owner: sig-network | 	// Owner: sig-network | ||||||
| 	// Marks a single test that tests cluster DNS performance with many services. | 	// Marks a single test that tests cluster DNS performance with many services. | ||||||
| 	PerformanceDNS = framework.WithFeature(framework.ValidFeatures.Add("PerformanceDNS")) | 	PerformanceDNS = framework.WithFeature(framework.ValidFeatures.Add("PerformanceDNS")) | ||||||
|   | |||||||
| @@ -29,7 +29,6 @@ import ( | |||||||
| 	"k8s.io/apimachinery/pkg/util/wait" | 	"k8s.io/apimachinery/pkg/util/wait" | ||||||
| 	admissionapi "k8s.io/pod-security-admission/api" | 	admissionapi "k8s.io/pod-security-admission/api" | ||||||
|  |  | ||||||
| 	"k8s.io/kubernetes/test/e2e/feature" |  | ||||||
| 	"k8s.io/kubernetes/test/e2e/framework" | 	"k8s.io/kubernetes/test/e2e/framework" | ||||||
| 	e2enode "k8s.io/kubernetes/test/e2e/framework/node" | 	e2enode "k8s.io/kubernetes/test/e2e/framework/node" | ||||||
| 	e2epod "k8s.io/kubernetes/test/e2e/framework/pod" | 	e2epod "k8s.io/kubernetes/test/e2e/framework/pod" | ||||||
| @@ -64,7 +63,7 @@ var ( | |||||||
|  |  | ||||||
| // This test verifies that a Pod on each node in a cluster can talk to Pods on every other node without SNAT. | // This test verifies that a Pod on each node in a cluster can talk to Pods on every other node without SNAT. | ||||||
| // We use the [Feature:NoSNAT] tag so that most jobs will skip this test by default. | // We use the [Feature:NoSNAT] tag so that most jobs will skip this test by default. | ||||||
| var _ = common.SIGDescribe("NoSNAT", feature.NoSNAT, framework.WithSlow(), func() { | var _ = common.SIGDescribe("NoSNAT", func() { | ||||||
| 	f := framework.NewDefaultFramework("no-snat-test") | 	f := framework.NewDefaultFramework("no-snat-test") | ||||||
| 	f.NamespacePodSecurityLevel = admissionapi.LevelPrivileged | 	f.NamespacePodSecurityLevel = admissionapi.LevelPrivileged | ||||||
| 	ginkgo.It("Should be able to send traffic between Pods without SNAT", func(ctx context.Context) { | 	ginkgo.It("Should be able to send traffic between Pods without SNAT", func(ctx context.Context) { | ||||||
| @@ -72,7 +71,7 @@ var _ = common.SIGDescribe("NoSNAT", feature.NoSNAT, framework.WithSlow(), func( | |||||||
| 		pc := cs.CoreV1().Pods(f.Namespace.Name) | 		pc := cs.CoreV1().Pods(f.Namespace.Name) | ||||||
|  |  | ||||||
| 		ginkgo.By("creating a test pod on each Node") | 		ginkgo.By("creating a test pod on each Node") | ||||||
| 		nodes, err := e2enode.GetReadySchedulableNodes(ctx, cs) | 		nodes, err := e2enode.GetBoundedReadySchedulableNodes(ctx, cs, 3) | ||||||
| 		framework.ExpectNoError(err) | 		framework.ExpectNoError(err) | ||||||
| 		gomega.Expect(nodes.Items).ToNot(gomega.BeEmpty(), "no Nodes in the cluster") | 		gomega.Expect(nodes.Items).ToNot(gomega.BeEmpty(), "no Nodes in the cluster") | ||||||
|  |  | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user
	 Antonio Ojea
					Antonio Ojea