github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-04 09:49:50 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #17784 from gmarek/testing

Browse Source 
Auto commit by PR queue bot
This commit is contained in:
k8s-merge-robot 2015-11-27 08:28:07 -08:00
commit 44f7983024
1 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
test/e2e/metrics_util.go
View File

@ -40,7 +40,10 @@ import (
const ( const (
podStartupThreshold time.Duration = 5 * time.Second podStartupThreshold time.Duration = 5 * time.Second
listPodLatencyThreshold time.Duration = 2 * time.Second // TODO: Decrease PodStartup latencies as soon as their perfomance improves
listPodLatencySmallThreshold time.Duration = 2 * time.Second
listPodLatencyMediumThreshold time.Duration = 4 * time.Second
listPodLatencyLargeThreshold time.Duration = 15 * time.Second
apiCallLatencySmallThreshold time.Duration = 250 * time.Millisecond apiCallLatencySmallThreshold time.Duration = 250 * time.Millisecond
apiCallLatencyMediumThreshold time.Duration = 500 * time.Millisecond apiCallLatencyMediumThreshold time.Duration = 500 * time.Millisecond
apiCallLatencyLargeThreshold time.Duration = 1 * time.Second apiCallLatencyLargeThreshold time.Duration = 1 * time.Second
@ -164,6 +167,16 @@ func apiCallLatencyThreshold(numNodes int) time.Duration {
return apiCallLatencyLargeThreshold return apiCallLatencyLargeThreshold
} }
func listPodsLatencyThreshold(numNodes int) time.Duration {
if numNodes <= 250 {
return listPodLatencySmallThreshold
}
if numNodes <= 500 {
return listPodLatencyMediumThreshold
}
return listPodLatencyLargeThreshold
}
// Prints top five summary metrics for request types with latency and returns // Prints top five summary metrics for request types with latency and returns
// number of such request types above threshold. // number of such request types above threshold.
func HighLatencyRequests(c *client.Client) (int, error) { func HighLatencyRequests(c *client.Client) (int, error) {
@ -182,7 +195,7 @@ func HighLatencyRequests(c *client.Client) (int, error) {
for _, metric := range metrics.APICalls { for _, metric := range metrics.APICalls {
threshold := apiCallLatencyThreshold(numNodes) threshold := apiCallLatencyThreshold(numNodes)
if metric.Verb == "LIST" && metric.Resource == "pods" { if metric.Verb == "LIST" && metric.Resource == "pods" {
threshold = listPodLatencyThreshold threshold = listPodsLatencyThreshold(numNodes)
} }
isBad := false isBad := false