Merge pull request #22281 from wojtek-t/increase_qps_limits

cmd/integration/integration.go

@@ -994,10 +994,22 @@ func main() {
 	// Wait for the synchronization threads to come up.
 	time.Sleep(time.Second * 10)
 
-	kubeClient := client.NewOrDie(&restclient.Config{Host: apiServerURL, ContentConfig: restclient.ContentConfig{GroupVersion: testapi.Default.GroupVersion()}})
+	kubeClient := client.NewOrDie(
+		&restclient.Config{
+			Host:          apiServerURL,
+			ContentConfig: restclient.ContentConfig{GroupVersion: testapi.Default.GroupVersion()},
+			QPS:           20,
+			Burst:         50,
+		})
 	// TODO: caesarxuchao: hacky way to specify version of Experimental client.
 	// We will fix this by supporting multiple group versions in Config
-	kubeClient.ExtensionsClient = client.NewExtensionsOrDie(&restclient.Config{Host: apiServerURL, ContentConfig: restclient.ContentConfig{GroupVersion: testapi.Extensions.GroupVersion()}})
+	kubeClient.ExtensionsClient = client.NewExtensionsOrDie(
+		&restclient.Config{
+			Host:          apiServerURL,
+			ContentConfig: restclient.ContentConfig{GroupVersion: testapi.Extensions.GroupVersion()},
+			QPS:           20,
+			Burst:         50,
+		})
 
 	// Run tests in parallel
 	testFuncs := []testFunc{

test/e2e/density.go

@@ -155,12 +155,8 @@ var _ = Describe("Density", func() {
 	})
 
 	// Explicitly put here, to delete namespace at the end of the test
-	// (after measuring latency metrics, etc.).framework := NewFramework("density")
-	options := FrameworkOptions{
-		clientQPS:   20,
-		clientBurst: 30,
-	}
-	framework := NewFramework("density", options)
+	// (after measuring latency metrics, etc.).
+	framework := NewDefaultFramework("density")
 	framework.NamespaceDeletionTimeout = time.Hour
 
 	BeforeEach(func() {

test/e2e/framework.go

@@ -84,8 +84,8 @@ type FrameworkOptions struct {
 // you (you can write additional before/after each functions).
 func NewDefaultFramework(baseName string) *Framework {
 	options := FrameworkOptions{
-		clientQPS:   5,
-		clientBurst: 10,
+		clientQPS:   20,
+		clientBurst: 50,
 	}
 	return NewFramework(baseName, options)
 }