-
Notifications
You must be signed in to change notification settings - Fork 98
/
views.go
57 lines (49 loc) · 2.31 KB
/
views.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
package views
import (
semconv "go.opentelemetry.io/collector/semconv/v1.13.0"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/sdk/instrumentation"
"go.opentelemetry.io/otel/sdk/metric"
)
var (
grpcScope = "go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc"
// grpcUnacceptableKeyValues is a list of high cardinality grpc attributes that should be filtered out.
grpcUnacceptableKeyValues = []attribute.KeyValue{
attribute.String(semconv.AttributeNetSockPeerAddr, ""),
attribute.String(semconv.AttributeNetSockPeerPort, ""),
attribute.String(semconv.AttributeNetSockPeerName, ""),
}
httpScope = "go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp"
// httpUnacceptableKeyValues is a list of high cardinality http attributes that should be filtered out.
httpUnacceptableKeyValues = []attribute.KeyValue{
attribute.String(semconv.AttributeNetHostName, ""),
attribute.String(semconv.AttributeNetHostPort, ""),
attribute.String(semconv.AttributeNetSockPeerPort, ""),
attribute.String(semconv.AttributeNetSockPeerAddr, ""),
attribute.String(semconv.AttributeHTTPClientIP, ""),
}
)
func cardinalityFilter(kvs ...attribute.KeyValue) attribute.Filter {
filter := attribute.NewSet(kvs...)
return func(kv attribute.KeyValue) bool {
return !filter.HasValue(kv.Key)
}
}
// DropHighCardinalityServerAttributes drops certain high cardinality attributes from grpc/http server metrics
//
// This is a fix to an upstream issue:
// https://github.com/open-telemetry/opentelemetry-go-contrib/issues/3765
// The long-term solution for the Collector is to set view settings in the Collector config:
// https://github.com/open-telemetry/opentelemetry-collector/issues/7517#issuecomment-1511168350
// In the future, when Collector supports such config, we may want to support similar view settings in Alloy.
func DropHighCardinalityServerAttributes() []metric.View {
var views []metric.View
views = append(views, metric.NewView(
metric.Instrument{Scope: instrumentation.Scope{Name: grpcScope}},
metric.Stream{AttributeFilter: cardinalityFilter(grpcUnacceptableKeyValues...)}))
views = append(views, metric.NewView(
metric.Instrument{Scope: instrumentation.Scope{Name: httpScope}},
metric.Stream{AttributeFilter: cardinalityFilter(httpUnacceptableKeyValues...)},
))
return views
}