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

lib/storage: make getSeriesCount func indexSearch method

Browse Source
This commit is contained in:
Aliaksandr Valialkin 2019-06-10 12:27:44 +03:00
parent 4c3913290a
commit e4cba5a7ed
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lib/storage/index_db.go
View File

@ -793,7 +793,7 @@ func (is *indexSearch) searchTagValues(tvs map[string]struct{}, prefix []byte, m
// up to two times - in db and extDB. // up to two times - in db and extDB.
func (db *indexDB) GetSeriesCount(accountID, projectID uint32) (uint64, error) { func (db *indexDB) GetSeriesCount(accountID, projectID uint32) (uint64, error) {
is := db.getIndexSearch() is := db.getIndexSearch()
n, err := getSeriesCount(accountID, projectID, &is.ts, &is.kb) n, err := is.getSeriesCount(accountID, projectID)
db.putIndexSearch(is) db.putIndexSearch(is)
if err != nil { if err != nil {
return 0, err return 0, err
@ -802,7 +802,7 @@ func (db *indexDB) GetSeriesCount(accountID, projectID uint32) (uint64, error) {
var nExt uint64 var nExt uint64
ok := db.doExtDB(func(extDB *indexDB) { ok := db.doExtDB(func(extDB *indexDB) {
is := extDB.getIndexSearch() is := extDB.getIndexSearch()
nExt, err = getSeriesCount(accountID, projectID, &is.ts, &is.kb) nExt, err = is.getSeriesCount(accountID, projectID)
extDB.putIndexSearch(is) extDB.putIndexSearch(is)
}) })
if ok && err != nil { if ok && err != nil {
@ -1157,7 +1157,9 @@ func (is *indexSearch) getTSIDByMetricID(dst *TSID, metricID uint64, accountID,
return nil return nil
} }
func getSeriesCount(accountID, projectID uint32, ts *mergeset.TableSearch, kb *bytesutil.ByteBuffer) (uint64, error) { func (is *indexSearch) getSeriesCount(accountID, projectID uint32) (uint64, error) {
ts := &is.ts
kb := &is.kb
var n uint64 var n uint64
kb.B = marshalCommonPrefix(kb.B[:0], nsPrefixMetricIDToTSID, accountID, projectID) kb.B = marshalCommonPrefix(kb.B[:0], nsPrefixMetricIDToTSID, accountID, projectID)
ts.Seek(kb.B) ts.Seek(kb.B)