Compare commits
No commits in common. "6d734004168608612c1370f752b7d7a37e38be2a" and "16bb306a042d443f383e7c6178badf86a1f4eb45" have entirely different histories.
6d73400416
...
16bb306a04
1 changed files with 3 additions and 7 deletions
|
@ -193,19 +193,15 @@ func (m *Metrics) collectReqeustDataMetrics(ch chan<- prometheus.Metric, queue *
|
||||||
sum += latency
|
sum += latency
|
||||||
count++
|
count++
|
||||||
|
|
||||||
|
var cumulativeCount uint64
|
||||||
for _, bound := range bucketBounds {
|
for _, bound := range bucketBounds {
|
||||||
if latency <= bound {
|
if latency <= bound {
|
||||||
buckets[bound]++
|
cumulativeCount++
|
||||||
}
|
}
|
||||||
|
buckets[bound] += cumulativeCount
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
var cumulativeCount uint64
|
|
||||||
for _, bound := range bucketBounds {
|
|
||||||
cumulativeCount += buckets[bound]
|
|
||||||
buckets[bound] = cumulativeCount
|
|
||||||
}
|
|
||||||
|
|
||||||
m.counter += uint(len(data))
|
m.counter += uint(len(data))
|
||||||
ch <- prometheus.MustNewConstMetric(
|
ch <- prometheus.MustNewConstMetric(
|
||||||
m.metricRequestsTotal,
|
m.metricRequestsTotal,
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue