mirror of https://github.com/linkerd/linkerd2.git
74 lines
2.4 KiB
Go
74 lines
2.4 KiB
Go
package injector
|
|
|
|
import (
|
|
"strings"
|
|
|
|
"github.com/linkerd/linkerd2/pkg/inject"
|
|
"github.com/linkerd/linkerd2/pkg/k8s"
|
|
"github.com/prometheus/client_golang/prometheus"
|
|
"github.com/prometheus/client_golang/prometheus/promauto"
|
|
)
|
|
|
|
const (
|
|
labelOwnerKind = "owner_kind"
|
|
labelNamespace = "namespace"
|
|
labelSkip = "skip"
|
|
labelAnnotationAt = "annotation_at"
|
|
labelReason = "skip_reason"
|
|
)
|
|
|
|
var (
|
|
requestLabels = []string{labelOwnerKind, labelNamespace, labelAnnotationAt}
|
|
responseLabels = []string{labelOwnerKind, labelNamespace, labelSkip, labelReason, labelAnnotationAt}
|
|
|
|
proxyInjectionAdmissionRequests = promauto.NewCounterVec(prometheus.CounterOpts{
|
|
Name: "proxy_inject_admission_requests_total",
|
|
Help: "A counter for number of admission requests to proxy injector.",
|
|
}, append(requestLabels, validLabelNames(inject.ProxyAnnotations)...))
|
|
|
|
proxyInjectionAdmissionResponses = promauto.NewCounterVec(prometheus.CounterOpts{
|
|
Name: "proxy_inject_admission_responses_total",
|
|
Help: "A counter for number of admission responses from proxy injector.",
|
|
}, append(responseLabels, validLabelNames(inject.ProxyAnnotations)...))
|
|
)
|
|
|
|
func admissionRequestLabels(ownerKind, namespace, annotationAt string, configLabels prometheus.Labels) prometheus.Labels {
|
|
configLabels[labelOwnerKind] = ownerKind
|
|
configLabels[labelNamespace] = namespace
|
|
configLabels[labelAnnotationAt] = annotationAt
|
|
return configLabels
|
|
}
|
|
|
|
func admissionResponseLabels(owner, namespace, skip, reason, annotationAt string, configLabels prometheus.Labels) prometheus.Labels {
|
|
configLabels[labelOwnerKind] = owner
|
|
configLabels[labelNamespace] = namespace
|
|
configLabels[labelSkip] = skip
|
|
configLabels[labelReason] = reason
|
|
configLabels[labelAnnotationAt] = annotationAt
|
|
return configLabels
|
|
}
|
|
|
|
func configToPrometheusLabels(conf *inject.ResourceConfig) prometheus.Labels {
|
|
labels := conf.GetOverriddenConfiguration()
|
|
promLabels := map[string]string{}
|
|
|
|
for label, value := range labels {
|
|
promLabels[validProxyConfigurationLabel(label)] = value
|
|
|
|
}
|
|
return promLabels
|
|
}
|
|
|
|
func validLabelNames(labels []string) []string {
|
|
var validLabels []string
|
|
|
|
for _, label := range labels {
|
|
validLabels = append(validLabels, validProxyConfigurationLabel(label))
|
|
}
|
|
return validLabels
|
|
}
|
|
|
|
func validProxyConfigurationLabel(label string) string {
|
|
return strings.ReplaceAll(label[len(k8s.ProxyConfigAnnotationsPrefix)+1:], "-", "_")
|
|
}
|