github/kubernetes
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Refactor and clean up e2e framework utils, this patch handles test/e2e/framework/kubelet_stats.go file

Browse Source
This commit is contained in:
WanLinghao
2019-07-29 16:23:58 +08:00
parent 3758426884
commit 92b0310cc5
18 changed files with 747 additions and 892 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
test/e2e_node/density_test.go
View File

@@ -454,8 +454,8 @@ func createBatchPodWithRateControl(f *framework.Framework, pods []*v1.Pod, inter
}
// getPodStartLatency gets prometheus metric 'pod start latency' from kubelet
func getPodStartLatency(node string) (framework.KubeletLatencyMetrics, error) {
latencyMetrics := framework.KubeletLatencyMetrics{}
func getPodStartLatency(node string) (e2emetrics.KubeletLatencyMetrics, error) {
latencyMetrics := e2emetrics.KubeletLatencyMetrics{}
ms, err := e2emetrics.GrabKubeletMetricsWithoutProxy(node, "/metrics")
framework.ExpectNoError(err, "Failed to get kubelet metrics without proxy in node %s", node)
@@ -464,7 +464,7 @@ func getPodStartLatency(node string) (framework.KubeletLatencyMetrics, error) {
if sample.Metric["__name__"] == kubemetrics.KubeletSubsystem+"_"+kubemetrics.PodStartDurationKey {
quantile, _ := strconv.ParseFloat(string(sample.Metric["quantile"]), 64)
latencyMetrics = append(latencyMetrics,
framework.KubeletLatencyMetric{
e2emetrics.KubeletLatencyMetric{
Quantile: quantile,
Method: kubemetrics.PodStartDurationKey,
Latency: time.Duration(int(sample.Value)) * time.Microsecond})