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

lib/storage: fix the search for empty label name (#2991)

Browse Source 
* lib/storage: fix the search for empty label name

Signed-off-by: hagen1778 <roman@victoriametrics.com>

* Apply suggestions from code review

Signed-off-by: hagen1778 <roman@victoriametrics.com>
Co-authored-by: Aliaksandr Valialkin <valyala@victoriametrics.com>
This commit is contained in:
Roman Khavronenko 2022-08-17 20:32:25 +02:00 committed by Aliaksandr Valialkin
parent 2256d51418
commit 2c59c83191
No known key found for this signature in database
GPG Key ID: A72BEC6CD3D0DED1
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
lib/storage/index_db.go
View File

@ -876,7 +876,7 @@ func (is *indexSearch) searchLabelNamesWithFiltersOnDate(qt *querytracer.Tracer,
if filter != nil && filter.Len() <= 100e3 { if filter != nil && filter.Len() <= 100e3 {
// It is faster to obtain label names by metricIDs from the filter // It is faster to obtain label names by metricIDs from the filter
// instead of scanning the inverted index for the matching filters. // instead of scanning the inverted index for the matching filters.
// This hould help https://github.com/VictoriaMetrics/VictoriaMetrics/issues/2978 // This would help https://github.com/VictoriaMetrics/VictoriaMetrics/issues/2978
metricIDs := filter.AppendTo(nil) metricIDs := filter.AppendTo(nil)
qt.Printf("sort %d metricIDs", len(metricIDs)) qt.Printf("sort %d metricIDs", len(metricIDs))
return is.getLabelNamesForMetricIDs(qt, metricIDs, lns, maxLabelNames) return is.getLabelNamesForMetricIDs(qt, metricIDs, lns, maxLabelNames)
@ -1072,7 +1072,7 @@ func (is *indexSearch) searchLabelValuesWithFiltersOnDate(qt *querytracer.Tracer
if filter != nil && filter.Len() < 100e3 { if filter != nil && filter.Len() < 100e3 {
// It is faster to obtain label values by metricIDs from the filter // It is faster to obtain label values by metricIDs from the filter
// instead of scanning the inverted index for the matching filters. // instead of scanning the inverted index for the matching filters.
// This hould help https://github.com/VictoriaMetrics/VictoriaMetrics/issues/2978 // This would help https://github.com/VictoriaMetrics/VictoriaMetrics/issues/2978
metricIDs := filter.AppendTo(nil) metricIDs := filter.AppendTo(nil)
qt.Printf("sort %d metricIDs", len(metricIDs)) qt.Printf("sort %d metricIDs", len(metricIDs))
return is.getLabelValuesForMetricIDs(qt, lvs, labelName, metricIDs, maxLabelValues) return is.getLabelValuesForMetricIDs(qt, lvs, labelName, metricIDs, maxLabelValues)
@ -1135,6 +1135,9 @@ func (is *indexSearch) searchLabelValuesWithFiltersOnDate(qt *querytracer.Tracer
} }
func (is *indexSearch) getLabelValuesForMetricIDs(qt *querytracer.Tracer, lvs map[string]struct{}, labelName string, metricIDs []uint64, maxLabelValues int) error { func (is *indexSearch) getLabelValuesForMetricIDs(qt *querytracer.Tracer, lvs map[string]struct{}, labelName string, metricIDs []uint64, maxLabelValues int) error {
if labelName == "" {
labelName = "__name__"
}
var mn MetricName var mn MetricName
foundLabelValues := 0 foundLabelValues := 0
var buf []byte var buf []byte