forked from kubernetes/kubernetes
-
Notifications
You must be signed in to change notification settings - Fork 100
/
metrics.go
56 lines (49 loc) · 1.47 KB
/
metrics.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
package servicecacertpublisher
import (
"strconv"
"sync"
"time"
apierrors "k8s.io/apimachinery/pkg/api/errors"
"k8s.io/component-base/metrics"
"k8s.io/component-base/metrics/legacyregistry"
)
// ServiceCACertPublisher - subsystem name used by service_ca_cert_publisher
const ServiceCACertPublisher = "service_ca_cert_publisher"
var (
syncCounter = metrics.NewCounterVec(
&metrics.CounterOpts{
Subsystem: ServiceCACertPublisher,
Name: "sync_total",
Help: "Number of namespace syncs happened in service ca cert publisher.",
StabilityLevel: metrics.ALPHA,
},
[]string{"code"},
)
syncLatency = metrics.NewHistogramVec(
&metrics.HistogramOpts{
Subsystem: ServiceCACertPublisher,
Name: "sync_duration_seconds",
Help: "Number of namespace syncs happened in service ca cert publisher.",
Buckets: metrics.ExponentialBuckets(0.001, 2, 15),
StabilityLevel: metrics.ALPHA,
},
[]string{"code"},
)
)
func recordMetrics(start time.Time, ns string, err error) {
code := "500"
if err == nil {
code = "200"
} else if se, ok := err.(*apierrors.StatusError); ok && se.Status().Code != 0 {
code = strconv.Itoa(int(se.Status().Code))
}
syncLatency.WithLabelValues(code).Observe(time.Since(start).Seconds())
syncCounter.WithLabelValues(code).Inc()
}
var once sync.Once
func registerMetrics() {
once.Do(func() {
legacyregistry.MustRegister(syncCounter)
legacyregistry.MustRegister(syncLatency)
})
}