github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-12-31 15:06:26 +00:00
Code Issues Projects Releases Packages Wiki Activity

wip

Browse source
This commit is contained in:
Aliaksandr Valialkin 2024-05-10 16:18:41 +02:00
parent b4fd20f17a
commit a4b2806330
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
2 changed files with 11 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
lib/logstorage/stats_count_uniq.go
View file

@ -369,11 +369,15 @@ func (sup *statsCountUniqProcessor) mergeState(sfp statsProcessor) {
func (sup *statsCountUniqProcessor) finalizeStats() string { func (sup *statsCountUniqProcessor) finalizeStats() string {
n := uint64(len(sup.m)) n := uint64(len(sup.m))
if limit := sup.su.limit; limit > 0 && n > limit {
n = limit
}
return strconv.FormatUint(n, 10) return strconv.FormatUint(n, 10)
} }
func (sup *statsCountUniqProcessor) limitReached() bool { func (sup *statsCountUniqProcessor) limitReached() bool {
return sup.su.limit > 0 && uint64(len(sup.m)) >= sup.su.limit limit := sup.su.limit
return limit > 0 && uint64(len(sup.m)) >= limit
} }
func parseStatsCountUniq(lex *lexer) (*statsCountUniq, error) { func parseStatsCountUniq(lex *lexer) (*statsCountUniq, error) {

7
lib/logstorage/stats_uniq_values.go
View file

@ -209,6 +209,10 @@ func (sup *statsUniqValuesProcessor) finalizeStats() string {
} }
slices.SortFunc(items, compareValues) slices.SortFunc(items, compareValues)
if limit := sup.su.limit; limit > 0 && uint64(len(items)) > limit {
items = items[:limit]
}
// Marshal items into JSON array. // Marshal items into JSON array.
// Pre-allocate buffer for serialized items. // Pre-allocate buffer for serialized items.
@ -232,7 +236,8 @@ func (sup *statsUniqValuesProcessor) finalizeStats() string {
} }
func (sup *statsUniqValuesProcessor) limitReached() bool { func (sup *statsUniqValuesProcessor) limitReached() bool {
return sup.su.limit > 0 && uint64(len(sup.m)) >= sup.su.limit limit := sup.su.limit
return limit > 0 && uint64(len(sup.m)) >= limit
} }
func compareValues(a, b string) int { func compareValues(a, b string) int {