Skip to content

Commit a04df83

Browse files
committed
add statusz for kubelet
1 parent a499fac commit a04df83

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

pkg/kubelet/server/server.go

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,8 @@ import (
6767
metricsfeatures "k8s.io/component-base/metrics/features"
6868
"k8s.io/component-base/metrics/legacyregistry"
6969
"k8s.io/component-base/metrics/prometheus/slis"
70+
zpagesfeatures "k8s.io/component-base/zpages/features"
71+
"k8s.io/component-base/zpages/statusz"
7072
runtimeapi "k8s.io/cri-api/pkg/apis/runtime/v1"
7173
"k8s.io/cri-client/pkg/util"
7274
podresourcesapi "k8s.io/kubelet/pkg/apis/podresources/v1"
@@ -105,6 +107,8 @@ const (
105107
debugFlagPath = "/debug/flags/v"
106108
podsPath = "/pods"
107109
runningPodsPath = "/runningpods/"
110+
111+
kubeletComponent = "kubelet"
108112
)
109113

110114
// Server is a http.Handler which exposes kubelet functionality over HTTP.
@@ -406,6 +410,10 @@ func (s *Server) InstallDefaultHandlers() {
406410
checkers = append(checkers, s.extendedCheckers...)
407411
healthz.InstallHandler(s.restfulCont, checkers...)
408412

413+
if utilfeature.DefaultFeatureGate.Enabled(zpagesfeatures.ComponentStatusz) {
414+
statusz.Install(s.restfulCont, kubeletComponent, statusz.NewRegistry())
415+
}
416+
409417
slis.SLIMetricsWithReset{}.Install(s.restfulCont)
410418

411419
s.addMetricsBucketMatcher("pods")

0 commit comments

Comments
 (0)