mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-30 23:15:14 +00:00
Compute avg and quantiles of scheduler throughput in density test
This commit is contained in:
parent
15cd355281
commit
979a8d73e1
@ -210,7 +210,10 @@ type SchedulingMetrics struct {
|
|||||||
SchedulingLatency LatencyMetric `json:"schedulingLatency"`
|
SchedulingLatency LatencyMetric `json:"schedulingLatency"`
|
||||||
BindingLatency LatencyMetric `json:"bindingLatency"`
|
BindingLatency LatencyMetric `json:"bindingLatency"`
|
||||||
E2ELatency LatencyMetric `json:"e2eLatency"`
|
E2ELatency LatencyMetric `json:"e2eLatency"`
|
||||||
ThroughputSamples []float64 `json:"throughputSamples"`
|
ThroughputAverage float64 `json:"throughputAverage"`
|
||||||
|
ThroughputPerc50 float64 `json:"throughputPerc50"`
|
||||||
|
ThroughputPerc90 float64 `json:"throughputPerc90"`
|
||||||
|
ThroughputPerc99 float64 `json:"throughputPerc99"`
|
||||||
}
|
}
|
||||||
|
|
||||||
func (l *SchedulingMetrics) SummaryKind() string {
|
func (l *SchedulingMetrics) SummaryKind() string {
|
||||||
|
@ -222,6 +222,24 @@ func density30AddonResourceVerifier(numNodes int) map[string]framework.ResourceC
|
|||||||
return constraints
|
return constraints
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func computeAverage(sample []float64) float64 {
|
||||||
|
sum := 0.0
|
||||||
|
for _, value := range sample {
|
||||||
|
sum += value
|
||||||
|
}
|
||||||
|
return sum / float64(len(sample))
|
||||||
|
}
|
||||||
|
|
||||||
|
func computeQuantile(sample []float64, quantile float64) float64 {
|
||||||
|
Expect(sort.Float64sAreSorted(sample)).To(Equal(true))
|
||||||
|
Expect(quantile >= 0.0 && quantile <= 1.0).To(Equal(true))
|
||||||
|
index := int(quantile*float64(len(sample))) - 1
|
||||||
|
if index < 0 {
|
||||||
|
return math.NaN()
|
||||||
|
}
|
||||||
|
return sample[index]
|
||||||
|
}
|
||||||
|
|
||||||
func logPodStartupStatus(
|
func logPodStartupStatus(
|
||||||
c clientset.Interface,
|
c clientset.Interface,
|
||||||
expectedPods int,
|
expectedPods int,
|
||||||
@ -400,7 +418,16 @@ var _ = SIGDescribe("Density", func() {
|
|||||||
latency, err := framework.VerifySchedulerLatency(c)
|
latency, err := framework.VerifySchedulerLatency(c)
|
||||||
framework.ExpectNoError(err)
|
framework.ExpectNoError(err)
|
||||||
if err == nil {
|
if err == nil {
|
||||||
latency.ThroughputSamples = scheduleThroughputs
|
// Compute avg and quantiles of throughput (excluding last element, that's usually an outlier).
|
||||||
|
sampleSize := len(scheduleThroughputs)
|
||||||
|
if sampleSize > 1 {
|
||||||
|
scheduleThroughputs = scheduleThroughputs[:sampleSize-1]
|
||||||
|
sort.Float64s(scheduleThroughputs)
|
||||||
|
latency.ThroughputAverage = computeAverage(scheduleThroughputs)
|
||||||
|
latency.ThroughputPerc50 = computeQuantile(scheduleThroughputs, 0.5)
|
||||||
|
latency.ThroughputPerc90 = computeQuantile(scheduleThroughputs, 0.9)
|
||||||
|
latency.ThroughputPerc99 = computeQuantile(scheduleThroughputs, 0.99)
|
||||||
|
}
|
||||||
summaries = append(summaries, latency)
|
summaries = append(summaries, latency)
|
||||||
}
|
}
|
||||||
summaries = append(summaries, testPhaseDurations)
|
summaries = append(summaries, testPhaseDurations)
|
||||||
|
Loading…
Reference in New Issue
Block a user