github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-24 04:06:03 +00:00
Code Issues Projects Releases Wiki Activity

apf integration test: ensure no rejection

Browse Source
This commit is contained in:
yue9944882 2020-07-23 14:40:50 +08:00
parent e6ee924f6c
commit 40f3242cd9
1 changed files with 20 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
test/integration/apiserver/flowcontrol/concurrency_test.go
View File

@ -44,6 +44,7 @@ import (
const ( const (
sharedConcurrencyMetricsName = "apiserver_flowcontrol_request_concurrency_limit" sharedConcurrencyMetricsName = "apiserver_flowcontrol_request_concurrency_limit"
dispatchedRequestCountMetricsName = "apiserver_flowcontrol_dispatched_requests_total" dispatchedRequestCountMetricsName = "apiserver_flowcontrol_dispatched_requests_total"
rejectedRequestCountMetricsName = "apiserver_flowcontrol_rejected_requests_total"
labelPriorityLevel = "priorityLevel" labelPriorityLevel = "priorityLevel"
timeout = time.Second * 10 timeout = time.Second * 10
) )
@ -122,13 +123,20 @@ func TestPriorityLevelIsolation(t *testing.T) {
time.Sleep(time.Second * 10) // running in background for a while time.Sleep(time.Second * 10) // running in background for a while
reqCounts, err := getRequestCountOfPriorityLevel(loopbackClient) allDispatchedReqCounts, rejectedReqCounts, err := getRequestCountOfPriorityLevel(loopbackClient)
if err != nil { if err != nil {
t.Error(err) t.Error(err)
} }
noxu1RequestCount := reqCounts[priorityLevelNoxu1.Name] noxu1RequestCount := allDispatchedReqCounts[priorityLevelNoxu1.Name]
noxu2RequestCount := reqCounts[priorityLevelNoxu2.Name] noxu2RequestCount := allDispatchedReqCounts[priorityLevelNoxu2.Name]
if rejectedReqCounts[priorityLevelNoxu1.Name] > 0 {
t.Errorf(`%v requests from the "elephant" stream were rejected unexpectedly`, rejectedReqCounts[priorityLevelNoxu2.Name])
}
if rejectedReqCounts[priorityLevelNoxu2.Name] > 0 {
t.Errorf(`%v requests from the "mouse" stream were rejected unexpectedly`, rejectedReqCounts[priorityLevelNoxu2.Name])
}
// Theoretically, the actual expected value of request counts upon the two priority-level should be // Theoretically, the actual expected value of request counts upon the two priority-level should be
// the equal. We're deliberately lax to make flakes super rare. // the equal. We're deliberately lax to make flakes super rare.
@ -192,10 +200,10 @@ func getSharedConcurrencyOfPriorityLevel(c clientset.Interface) (map[string]int,
} }
} }
func getRequestCountOfPriorityLevel(c clientset.Interface) (map[string]int, error) { func getRequestCountOfPriorityLevel(c clientset.Interface) (map[string]int, map[string]int, error) {
resp, err := getMetrics(c) resp, err := getMetrics(c)
if err != nil { if err != nil {
return nil, err return nil, nil, err
} }
dec := expfmt.NewDecoder(strings.NewReader(string(resp)), expfmt.FmtText) dec := expfmt.NewDecoder(strings.NewReader(string(resp)), expfmt.FmtText)
@ -204,20 +212,23 @@ func getRequestCountOfPriorityLevel(c clientset.Interface) (map[string]int, erro
Opts: &expfmt.DecodeOptions{}, Opts: &expfmt.DecodeOptions{},
} }
reqCounts := make(map[string]int) allReqCounts := make(map[string]int)
rejectReqCounts := make(map[string]int)
for { for {
var v model.Vector var v model.Vector
if err := decoder.Decode(&v); err != nil { if err := decoder.Decode(&v); err != nil {
if err == io.EOF { if err == io.EOF {
// Expected loop termination condition. // Expected loop termination condition.
return reqCounts, nil return allReqCounts, rejectReqCounts, nil
} }
return nil, fmt.Errorf("failed decoding metrics: %v", err) return nil, nil, fmt.Errorf("failed decoding metrics: %v", err)
} }
for _, metric := range v { for _, metric := range v {
switch name := string(metric.Metric[model.MetricNameLabel]); name { switch name := string(metric.Metric[model.MetricNameLabel]); name {
case dispatchedRequestCountMetricsName: case dispatchedRequestCountMetricsName:
reqCounts[string(metric.Metric[labelPriorityLevel])] = int(metric.Value) allReqCounts[string(metric.Metric[labelPriorityLevel])] = int(metric.Value)
case rejectedRequestCountMetricsName:
rejectReqCounts[string(metric.Metric[labelPriorityLevel])] = int(metric.Value)
} }
} }
} }