apitech
/
prometheus
mirror of https://github.com/prometheus/prometheus
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Merge pull request #16697 from Konstantinov-Innokentii/export-query-samples-fields

Browse Source 
stats: Export QuerySamples StartTimestamp and Interval fields
beorn7/testing
Björn Rabenstein 2 weeks ago committed by GitHub
parent c528293376 cd5bd11bd8
commit ea75bc18e9
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 6 additions and 6 deletions
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Show Stats Download Patch File Download Diff File
  1. 12
      util/stats/query_stats.go

12
util/stats/query_stats.go
Unescape View File

@ -182,7 +182,7 @@ func (qs *QuerySamples) totalSamplesPerStepPoints() []stepStat {
ts := make([]stepStat, len(qs.TotalSamplesPerStep)) ts := make([]stepStat, len(qs.TotalSamplesPerStep))
for i, c := range qs.TotalSamplesPerStep { for i, c := range qs.TotalSamplesPerStep {
ts[i] = stepStat{T: qs.startTimestamp + int64(i)*qs.interval, V: c} ts[i] = stepStat{T: qs.StartTimestamp + int64(i)*qs.Interval, V: c}
} }
return ts return ts
} }
@ -246,8 +246,8 @@ type QuerySamples struct {
TotalSamplesPerStep []int64 TotalSamplesPerStep []int64
EnablePerStepStats bool EnablePerStepStats bool
startTimestamp int64 StartTimestamp int64
interval int64 Interval int64
} }
type Stats struct { type Stats struct {
@ -262,8 +262,8 @@ func (qs *QuerySamples) InitStepTracking(start, end, interval int64) {
numSteps := int((end-start)/interval) + 1 numSteps := int((end-start)/interval) + 1
qs.TotalSamplesPerStep = make([]int64, numSteps) qs.TotalSamplesPerStep = make([]int64, numSteps)
qs.startTimestamp = start qs.StartTimestamp = start
qs.interval = interval qs.Interval = interval
} }
// IncrementSamplesAtStep increments the total samples count. Use this if you know the step index. // IncrementSamplesAtStep increments the total samples count. Use this if you know the step index.
@ -287,7 +287,7 @@ func (qs *QuerySamples) IncrementSamplesAtTimestamp(t, samples int64) {
qs.TotalSamples += samples qs.TotalSamples += samples
if qs.TotalSamplesPerStep != nil { if qs.TotalSamplesPerStep != nil {
i := int((t - qs.startTimestamp) / qs.interval) i := int((t - qs.StartTimestamp) / qs.Interval)
qs.TotalSamplesPerStep[i] += samples qs.TotalSamplesPerStep[i] += samples
} }
} }

Write Preview
Loading…
Cancel
Save