Kiu/VictoriaMetrics
Kiu/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-12-15 08:23:34 +01:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

app/vmselect/prometheus: minimize the diff for the change 1033dc7e2a over 619b0a25c9

Browse Source
This commit is contained in:
Aliaksandr Valialkin 2020-07-13 21:40:38 +03:00
parent bf39e67ade
commit 3898cc0285
2 changed files with 79 additions and 73 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
app/vmselect/prometheus/util.qtpl
View File

@ -21,24 +21,26 @@
{% endfunc %} {% endfunc %}
{% func valuesWithTimestamps(values []float64, timestamps []int64) %} {% func valuesWithTimestamps(values []float64, timestamps []int64) %}
{% if len(values) == 0 %}
[]
{% return %}
{% endif %}
[ [
{% code /* inline metricRow call here for the sake of performance optimization */ %}
[{%f= float64(timestamps[0])/1e3 %},"{%f= values[0] %}"]
{% code
timestamps = timestamps[1:]
values = values[1:]
%}
{% if len(values) > 0 %} {% if len(values) > 0 %}
{% code /* inline metricRow call here for the sake of performance optimization */ %} {%code
[{%f= float64(timestamps[0])/1e3 %},"{%f= values[0] %}"] // Remove bounds check inside the loop below
{% code _ = timestamps[len(values)-1]
timestamps = timestamps[1:]
values = values[1:]
%} %}
{% if len(values) > 0 %} {% for i, v := range values %}
{%code {% code /* inline metricRow call here for the sake of performance optimization */ %}
// Remove bounds check inside the loop below ,[{%f= float64(timestamps[i])/1e3 %},"{%f= v %}"]
_ = timestamps[len(values)-1] {% endfor %}
%}
{% for i, v := range values %}
{% code /* inline metricRow call here for the sake of performance optimization */ %}
,[{%f= float64(timestamps[i])/1e3 %},"{%f= v %}"]
{% endfor %}
{% endif %}
{% endif %} {% endif %}
] ]
{% endfunc %} {% endfunc %}

120
app/vmselect/prometheus/util.qtpl.go
View File

@ -133,81 +133,85 @@ func metricRow(timestamp int64, value float64) string {
//line app/vmselect/prometheus/util.qtpl:23 //line app/vmselect/prometheus/util.qtpl:23
func streamvaluesWithTimestamps(qw422016 *qt422016.Writer, values []float64, timestamps []int64) { func streamvaluesWithTimestamps(qw422016 *qt422016.Writer, values []float64, timestamps []int64) {
//line app/vmselect/prometheus/util.qtpl:23 //line app/vmselect/prometheus/util.qtpl:24
qw422016.N().S(`[`) if len(values) == 0 {
//line app/vmselect/prometheus/util.qtpl:25 //line app/vmselect/prometheus/util.qtpl:24
if len(values) > 0 { qw422016.N().S(`[]`)
//line app/vmselect/prometheus/util.qtpl:26 //line app/vmselect/prometheus/util.qtpl:26
/* inline metricRow call here for the sake of performance optimization */ return
//line app/vmselect/prometheus/util.qtpl:26
qw422016.N().S(`[`)
//line app/vmselect/prometheus/util.qtpl:27 //line app/vmselect/prometheus/util.qtpl:27
qw422016.N().F(float64(timestamps[0]) / 1e3)
//line app/vmselect/prometheus/util.qtpl:27
qw422016.N().S(`,"`)
//line app/vmselect/prometheus/util.qtpl:27
qw422016.N().F(values[0])
//line app/vmselect/prometheus/util.qtpl:27
qw422016.N().S(`"]`)
//line app/vmselect/prometheus/util.qtpl:29
timestamps = timestamps[1:]
values = values[1:]
//line app/vmselect/prometheus/util.qtpl:32
if len(values) > 0 {
//line app/vmselect/prometheus/util.qtpl:34
// Remove bounds check inside the loop below
_ = timestamps[len(values)-1]
//line app/vmselect/prometheus/util.qtpl:37
for i, v := range values {
//line app/vmselect/prometheus/util.qtpl:38
/* inline metricRow call here for the sake of performance optimization */
//line app/vmselect/prometheus/util.qtpl:38
qw422016.N().S(`,[`)
//line app/vmselect/prometheus/util.qtpl:39
qw422016.N().F(float64(timestamps[i]) / 1e3)
//line app/vmselect/prometheus/util.qtpl:39
qw422016.N().S(`,"`)
//line app/vmselect/prometheus/util.qtpl:39
qw422016.N().F(v)
//line app/vmselect/prometheus/util.qtpl:39
qw422016.N().S(`"]`)
//line app/vmselect/prometheus/util.qtpl:40
}
//line app/vmselect/prometheus/util.qtpl:41
}
//line app/vmselect/prometheus/util.qtpl:42
} }
//line app/vmselect/prometheus/util.qtpl:27
qw422016.N().S(`[`)
//line app/vmselect/prometheus/util.qtpl:29
/* inline metricRow call here for the sake of performance optimization */
//line app/vmselect/prometheus/util.qtpl:29
qw422016.N().S(`[`)
//line app/vmselect/prometheus/util.qtpl:30
qw422016.N().F(float64(timestamps[0]) / 1e3)
//line app/vmselect/prometheus/util.qtpl:30
qw422016.N().S(`,"`)
//line app/vmselect/prometheus/util.qtpl:30
qw422016.N().F(values[0])
//line app/vmselect/prometheus/util.qtpl:30
qw422016.N().S(`"]`)
//line app/vmselect/prometheus/util.qtpl:32
timestamps = timestamps[1:]
values = values[1:]
//line app/vmselect/prometheus/util.qtpl:35
if len(values) > 0 {
//line app/vmselect/prometheus/util.qtpl:37
// Remove bounds check inside the loop below
_ = timestamps[len(values)-1]
//line app/vmselect/prometheus/util.qtpl:40
for i, v := range values {
//line app/vmselect/prometheus/util.qtpl:41
/* inline metricRow call here for the sake of performance optimization */
//line app/vmselect/prometheus/util.qtpl:41
qw422016.N().S(`,[`)
//line app/vmselect/prometheus/util.qtpl:42 //line app/vmselect/prometheus/util.qtpl:42
qw422016.N().F(float64(timestamps[i]) / 1e3)
//line app/vmselect/prometheus/util.qtpl:42
qw422016.N().S(`,"`)
//line app/vmselect/prometheus/util.qtpl:42
qw422016.N().F(v)
//line app/vmselect/prometheus/util.qtpl:42
qw422016.N().S(`"]`)
//line app/vmselect/prometheus/util.qtpl:43
}
//line app/vmselect/prometheus/util.qtpl:44
}
//line app/vmselect/prometheus/util.qtpl:44
qw422016.N().S(`]`) qw422016.N().S(`]`)
//line app/vmselect/prometheus/util.qtpl:44 //line app/vmselect/prometheus/util.qtpl:46
} }
//line app/vmselect/prometheus/util.qtpl:44 //line app/vmselect/prometheus/util.qtpl:46
func writevaluesWithTimestamps(qq422016 qtio422016.Writer, values []float64, timestamps []int64) { func writevaluesWithTimestamps(qq422016 qtio422016.Writer, values []float64, timestamps []int64) {
//line app/vmselect/prometheus/util.qtpl:44 //line app/vmselect/prometheus/util.qtpl:46
qw422016 := qt422016.AcquireWriter(qq422016) qw422016 := qt422016.AcquireWriter(qq422016)
//line app/vmselect/prometheus/util.qtpl:44 //line app/vmselect/prometheus/util.qtpl:46
streamvaluesWithTimestamps(qw422016, values, timestamps) streamvaluesWithTimestamps(qw422016, values, timestamps)
//line app/vmselect/prometheus/util.qtpl:44 //line app/vmselect/prometheus/util.qtpl:46
qt422016.ReleaseWriter(qw422016) qt422016.ReleaseWriter(qw422016)
//line app/vmselect/prometheus/util.qtpl:44 //line app/vmselect/prometheus/util.qtpl:46
} }
//line app/vmselect/prometheus/util.qtpl:44 //line app/vmselect/prometheus/util.qtpl:46
func valuesWithTimestamps(values []float64, timestamps []int64) string { func valuesWithTimestamps(values []float64, timestamps []int64) string {
//line app/vmselect/prometheus/util.qtpl:44 //line app/vmselect/prometheus/util.qtpl:46
qb422016 := qt422016.AcquireByteBuffer() qb422016 := qt422016.AcquireByteBuffer()
//line app/vmselect/prometheus/util.qtpl:44 //line app/vmselect/prometheus/util.qtpl:46
writevaluesWithTimestamps(qb422016, values, timestamps) writevaluesWithTimestamps(qb422016, values, timestamps)
//line app/vmselect/prometheus/util.qtpl:44 //line app/vmselect/prometheus/util.qtpl:46
qs422016 := string(qb422016.B) qs422016 := string(qb422016.B)
//line app/vmselect/prometheus/util.qtpl:44 //line app/vmselect/prometheus/util.qtpl:46
qt422016.ReleaseByteBuffer(qb422016) qt422016.ReleaseByteBuffer(qb422016)
//line app/vmselect/prometheus/util.qtpl:44 //line app/vmselect/prometheus/util.qtpl:46
return qs422016 return qs422016
//line app/vmselect/prometheus/util.qtpl:44 //line app/vmselect/prometheus/util.qtpl:46
} }