mirror of
https://github.com/hanzoai/otel-collector.git
synced 2026-11-03 02:20:04 +00:00
zeekay
54ffd7aa85
- imports: ClickHouse/ch-go, clickhouse-go/v2, srikanthccv/ClickHouse-go-mock
-> github.com/hanzo-ds/{native,go,mock} (require, clean semver, NO replace)
- identifiers/aliases/type-names/config-keys/type-IDs: clickhouse -> datastore
(receiver dir clickhousesystemtablesreceiver -> datastoresystemtablesreceiver)
- DSN scheme clickhouse:// -> datastore:// (driver treats non-http/https as Native)
- removed the go.opencensus.io version-pin replace (require-pinned instead)
- kept: real external refs (github.com/ClickHouse, clickhouse.com docs) and the
hanzo-ds/mock test API (NewClickHouseNative) pending the mock's own rename
Full ./... build passes. 0 replace directives, 0 signoz.
66 lines
1.5 KiB
Go
66 lines
1.5 KiB
Go
package fingerprint
|
|
|
|
import (
|
|
"sort"
|
|
)
|
|
|
|
func NewLabelsAsJSONString(name string, ms ...map[string]string) string {
|
|
attrs := make(map[string]string)
|
|
for _, m := range ms {
|
|
for k, v := range m {
|
|
attrs[k] = v
|
|
}
|
|
}
|
|
|
|
attrs["__name__"] = name
|
|
return string(marshalLabels(attrs, make([]byte, 0, 128)))
|
|
}
|
|
|
|
// marshalLabels marshals attributes into JSON, appending it to b.
|
|
// It preserves an order. It is also significantly faster then json.Marshal.
|
|
// It is compatible with Datastore JSON functions: https://datastore.yandex/docs/en/functions/json_functions.html
|
|
func marshalLabels(attrs map[string]string, b []byte) []byte {
|
|
// make sure that the attrs are sorted
|
|
keys := make([]string, 0, len(attrs))
|
|
for k := range attrs {
|
|
keys = append(keys, k)
|
|
}
|
|
sort.SliceStable(keys, func(i, j int) bool {
|
|
return keys[i] < keys[j]
|
|
})
|
|
|
|
if len(attrs) == 0 {
|
|
return append(b, '{', '}')
|
|
}
|
|
|
|
b = append(b, '{')
|
|
for _, name := range keys {
|
|
value := attrs[name]
|
|
// add label name which can't contain runes that should be escaped
|
|
b = append(b, '"')
|
|
b = append(b, name...)
|
|
b = append(b, '"', ':', '"')
|
|
|
|
// add label value while escaping some runes
|
|
for _, c := range []byte(value) {
|
|
switch c {
|
|
case '\\', '"':
|
|
b = append(b, '\\', c)
|
|
case '\n':
|
|
b = append(b, '\\', 'n')
|
|
case '\r':
|
|
b = append(b, '\\', 'r')
|
|
case '\t':
|
|
b = append(b, '\\', 't')
|
|
default:
|
|
b = append(b, c)
|
|
}
|
|
}
|
|
|
|
b = append(b, '"', ',')
|
|
}
|
|
b[len(b)-1] = '}' // replace last comma
|
|
|
|
return b
|
|
}
|