mirror of
https://github.com/VictoriaMetrics/VictoriaMetrics.git
synced 2024-12-28 23:00:03 +01:00
33 lines
935 B
Go
33 lines
935 B
Go
|
package common
|
||
|
|
||
|
import (
|
||
|
"flag"
|
||
|
"sort"
|
||
|
|
||
|
"github.com/VictoriaMetrics/VictoriaMetrics/lib/prompb"
|
||
|
)
|
||
|
|
||
|
var sortLabels = flag.Bool("sortLabels", false, `Whether to sort labels for incoming samples before writing them to storage. `+
|
||
|
`This may be needed for reducing memory usage at storage when the order of labels in incoming samples is random. `+
|
||
|
`For example, if m{k1="v1",k2="v2"} may be sent as m{k2="v2",k1="v1"}. `+
|
||
|
`Enabled sorting for labels can slow down ingestion performance a bit`)
|
||
|
|
||
|
// SortLabelsIfNeeded sorts labels if -sortLabels command-line flag is set
|
||
|
func (ctx *InsertCtx) SortLabelsIfNeeded() {
|
||
|
if *sortLabels {
|
||
|
sort.Sort(&ctx.Labels)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
type sortedLabels []prompb.Label
|
||
|
|
||
|
func (sl *sortedLabels) Len() int { return len(*sl) }
|
||
|
func (sl *sortedLabels) Less(i, j int) bool {
|
||
|
a := *sl
|
||
|
return string(a[i].Name) < string(a[j].Name)
|
||
|
}
|
||
|
func (sl *sortedLabels) Swap(i, j int) {
|
||
|
a := *sl
|
||
|
a[i], a[j] = a[j], a[i]
|
||
|
}
|