@@ -21,6 +21,7 @@ import (
2121 "crypto/md5" //nolint:gosec
2222 "encoding/binary"
2323 "fmt"
24+ "log/slog"
2425 "net"
2526 "net/http"
2627 "net/http/pprof"
@@ -30,6 +31,8 @@ import (
3031 "strings"
3132 "time"
3233
34+ "github.com/go-logr/logr"
35+
3336 "gopkg.in/yaml.v3"
3437 "k8s.io/client-go/kubernetes"
3538 _ "k8s.io/client-go/plugin/pkg/client/auth" // Initialize common client auth plugins.
@@ -66,19 +69,6 @@ const (
6669 readyzPath = "/readyz"
6770)
6871
69- // promLogger implements promhttp.Logger
70- type promLogger struct {}
71-
72- func (pl promLogger ) Println (v ... interface {}) {
73- klog .Error (v ... )
74- }
75-
76- // promLogger implements the Logger interface
77- func (pl promLogger ) Log (v ... interface {}) error {
78- klog .Info (v ... )
79- return nil
80- }
81-
8272// RunKubeStateMetricsWrapper runs KSM with context cancellation.
8373func RunKubeStateMetricsWrapper (ctx context.Context , opts * options.Options ) error {
8474 err := RunKubeStateMetrics (ctx , opts )
@@ -93,7 +83,6 @@ func RunKubeStateMetricsWrapper(ctx context.Context, opts *options.Options) erro
9383// Any out-of-tree custom resource metrics could be registered by newing a registry factory
9484// which implements customresource.RegistryFactory and pass all factories into this function.
9585func RunKubeStateMetrics (ctx context.Context , opts * options.Options ) error {
96- promLogger := promLogger {}
9786 ksmMetricsRegistry := prometheus .NewRegistry ()
9887 ksmMetricsRegistry .MustRegister (versionCollector .NewCollector ("kube_state_metrics" ))
9988 durationVec := promauto .With (ksmMetricsRegistry ).NewHistogramVec (
@@ -359,11 +348,14 @@ func RunKubeStateMetrics(ctx context.Context, opts *options.Options) error {
359348 WebConfigFile : & tlsConfig ,
360349 }
361350
351+ handler := logr .ToSlogHandler (klog .Background ())
352+ sLogger := slog .New (handler )
353+
362354 // Run Telemetry server
363355 {
364356 g .Add (func () error {
365357 klog .InfoS ("Started kube-state-metrics self metrics server" , "telemetryAddress" , telemetryListenAddress )
366- return web .ListenAndServe (& telemetryServer , & telemetryFlags , promLogger )
358+ return web .ListenAndServe (& telemetryServer , & telemetryFlags , sLogger )
367359 }, func (error ) {
368360 ctxShutDown , cancel := context .WithTimeout (ctx , 3 * time .Second )
369361 defer cancel ()
@@ -374,7 +366,7 @@ func RunKubeStateMetrics(ctx context.Context, opts *options.Options) error {
374366 {
375367 g .Add (func () error {
376368 klog .InfoS ("Started metrics server" , "metricsServerAddress" , metricsServerListenAddress )
377- return web .ListenAndServe (& metricsServer , & metricsFlags , promLogger )
369+ return web .ListenAndServe (& metricsServer , & metricsFlags , sLogger )
378370 }, func (error ) {
379371 ctxShutDown , cancel := context .WithTimeout (ctx , 3 * time .Second )
380372 defer cancel ()
@@ -393,8 +385,11 @@ func RunKubeStateMetrics(ctx context.Context, opts *options.Options) error {
393385func buildTelemetryServer (registry prometheus.Gatherer ) * http.ServeMux {
394386 mux := http .NewServeMux ()
395387
388+ handler := logr .ToSlogHandler (klog .Background ())
389+ sLogger := slog .NewLogLogger (handler , slog .LevelError )
390+
396391 // Add metricsPath
397- mux .Handle (metricsPath , promhttp .HandlerFor (registry , promhttp.HandlerOpts {ErrorLog : promLogger {} }))
392+ mux .Handle (metricsPath , promhttp .HandlerFor (registry , promhttp.HandlerOpts {ErrorLog : sLogger }))
398393
399394 // Add readyzPath
400395 mux .Handle (readyzPath , http .HandlerFunc (func (w http.ResponseWriter , _ * http.Request ) {
0 commit comments