Skip to content

Commit

Permalink
Merge pull request #97074 from adtac/apfe2e-4
Browse files Browse the repository at this point in the history
APF e2e: disable drown-out tests temporarily
  • Loading branch information
k8s-ci-robot committed Dec 4, 2020
2 parents a744bdd + 922548b commit c4cf0d4
Showing 1 changed file with 14 additions and 7 deletions.
21 changes: 14 additions & 7 deletions test/e2e/apimachinery/flowcontrol.go
Original file line number Diff line number Diff line change
Expand Up @@ -74,6 +74,9 @@ var _ = SIGDescribe("API priority and fairness", func() {
// higher QPS client cannot drown out the other one despite having higher
// priority.
ginkgo.It("should ensure that requests can't be drowned out (priority)", func() {
// See https://github.com/kubernetes/kubernetes/issues/96710
ginkgo.Skip("skipping test until flakiness is resolved")

flowSchemaNamePrefix := "e2e-testing-flowschema-" + f.UniqueName
priorityLevelNamePrefix := "e2e-testing-prioritylevel-" + f.UniqueName
loadDuration := 10 * time.Second
Expand All @@ -83,13 +86,13 @@ var _ = SIGDescribe("API priority and fairness", func() {
type client struct {
username string
qps float64
priorityLevelName string
concurrencyMultiplier float64
priorityLevelName string //lint:ignore U1000 field is actually used
concurrencyMultiplier float64 //lint:ignore U1000 field is actually used
concurrency int32
flowSchemaName string
matchingPrecedence int32
flowSchemaName string //lint:ignore U1000 field is actually used
matchingPrecedence int32 //lint:ignore U1000 field is actually used
completedRequests int32
expectedCompletedPercentage float64
expectedCompletedPercentage float64 //lint:ignore U1000 field is actually used
}
clients := []client{
// "highqps" refers to a client that creates requests at a much higher
Expand Down Expand Up @@ -154,6 +157,9 @@ var _ = SIGDescribe("API priority and fairness", func() {
// the two clients and not allow one client to drown out the other despite
// having a higher QPS.
ginkgo.It("should ensure that requests can't be drowned out (fairness)", func() {
// See https://github.com/kubernetes/kubernetes/issues/96710
ginkgo.Skip("skipping test until flakiness is resolved")

priorityLevelName := "e2e-testing-prioritylevel-" + f.UniqueName
flowSchemaName := "e2e-testing-flowschema-" + f.UniqueName
loadDuration := 10 * time.Second
Expand All @@ -171,10 +177,10 @@ var _ = SIGDescribe("API priority and fairness", func() {
type client struct {
username string
qps float64
concurrencyMultiplier float64
concurrencyMultiplier float64 //lint:ignore U1000 field is actually used
concurrency int32
completedRequests int32
expectedCompletedPercentage float64
expectedCompletedPercentage float64 //lint:ignore U1000 field is actually used
}
clients := []client{
{username: highQPSClientName, qps: 100.0, concurrencyMultiplier: 2.0, expectedCompletedPercentage: 0.75},
Expand Down Expand Up @@ -242,6 +248,7 @@ func createPriorityLevel(f *framework.Framework, priorityLevelName string, assur
}
}

//lint:ignore U1000 function is actually referenced
func getPriorityLevelConcurrency(f *framework.Framework, priorityLevelName string) int32 {
resp, err := f.ClientSet.CoreV1().RESTClient().Get().RequestURI("/metrics").DoRaw(context.TODO())
framework.ExpectNoError(err)
Expand Down

0 comments on commit c4cf0d4

Please sign in to comment.