5ec4a4dab8
Merge in DNS/adguard-home from 4142-stats-panic to master Updates #4142. Squashed commit of the following: commit bf168f50ac86bdfdab73bf7285705f09f87b6c72 Author: Eugene Burkov <E.Burkov@AdGuard.COM> Date: Thu Jan 20 17:13:41 2022 +0300 stats: imp more commit bb638211da7d0c51959ded2dacb72faea00befb4 Author: Eugene Burkov <E.Burkov@AdGuard.COM> Date: Thu Jan 20 17:09:31 2022 +0300 stats: imp code quality commit 27ac52f15e4e0f4112ce7a6b47b03f963463393e Author: Eugene Burkov <E.Burkov@AdGuard.COM> Date: Thu Jan 20 17:00:09 2022 +0300 stats: recover panic on init commit 1ffcebbb9062438170b010e1c7bad3c6cef4cfc1 Author: Eugene Burkov <E.Burkov@AdGuard.COM> Date: Thu Jan 20 14:19:01 2022 +0300 all: fix some typos
76 lines
1.8 KiB
Go
76 lines
1.8 KiB
Go
// Package aghalg contains common generic algorithms and data structures.
|
|
//
|
|
// TODO(a.garipov): Update to use type parameters in Go 1.18.
|
|
package aghalg
|
|
|
|
import (
|
|
"fmt"
|
|
"sort"
|
|
)
|
|
|
|
// comparable is an alias for interface{}. Values passed as arguments of this
|
|
// type alias must be comparable.
|
|
//
|
|
// TODO(a.garipov): Remove in Go 1.18.
|
|
type comparable = interface{}
|
|
|
|
// UniqChecker allows validating uniqueness of comparable items.
|
|
type UniqChecker map[comparable]int64
|
|
|
|
// Add adds a value to the validator. v must not be nil.
|
|
func (uc UniqChecker) Add(elems ...comparable) {
|
|
for _, e := range elems {
|
|
uc[e]++
|
|
}
|
|
}
|
|
|
|
// Merge returns a checker containing data from both uc and other.
|
|
func (uc UniqChecker) Merge(other UniqChecker) (merged UniqChecker) {
|
|
merged = make(UniqChecker, len(uc)+len(other))
|
|
for elem, num := range uc {
|
|
merged[elem] += num
|
|
}
|
|
|
|
for elem, num := range other {
|
|
merged[elem] += num
|
|
}
|
|
|
|
return merged
|
|
}
|
|
|
|
// Validate returns an error enumerating all elements that aren't unique.
|
|
// isBefore is an optional sorting function to make the error message
|
|
// deterministic.
|
|
func (uc UniqChecker) Validate(isBefore func(a, b comparable) (less bool)) (err error) {
|
|
var dup []comparable
|
|
for elem, num := range uc {
|
|
if num > 1 {
|
|
dup = append(dup, elem)
|
|
}
|
|
}
|
|
|
|
if len(dup) == 0 {
|
|
return nil
|
|
}
|
|
|
|
if isBefore != nil {
|
|
sort.Slice(dup, func(i, j int) (less bool) {
|
|
return isBefore(dup[i], dup[j])
|
|
})
|
|
}
|
|
|
|
return fmt.Errorf("duplicated values: %v", dup)
|
|
}
|
|
|
|
// IntIsBefore is a helper sort function for UniqChecker.Validate.
|
|
// a and b must be of type int.
|
|
func IntIsBefore(a, b comparable) (less bool) {
|
|
return a.(int) < b.(int)
|
|
}
|
|
|
|
// StringIsBefore is a helper sort function for UniqChecker.Validate.
|
|
// a and b must be of type string.
|
|
func StringIsBefore(a, b comparable) (less bool) {
|
|
return a.(string) < b.(string)
|
|
}
|