replace klog with controller-runtime/log

Signed-off-by: Etai Lev Ran <elevran@gmail.com>

Author: elevran

pkg/sidecar/proxy/allowlist.go

@@ -33,8 +33,8 @@ import (
 	"k8s.io/client-go/dynamic"
 	"k8s.io/client-go/tools/cache"
 	"k8s.io/client-go/tools/clientcmd"
-	"k8s.io/klog/v2"
 	"k8s.io/utils/set"
+	"sigs.k8s.io/controller-runtime/pkg/log"
 )
 
 const (
@@ -105,7 +105,7 @@ func (av *AllowlistValidator) Start(ctx context.Context) error {
 		return nil
 	}
 
-	av.logger = klog.FromContext(ctx).WithName("allowlist-validator")
+	av.logger = log.FromContext(ctx).WithName("allowlist-validator")
 	av.logger.Info("starting SSRF protection allowlist validator", "namespace", av.namespace, "poolName", av.poolName)
 
 	gvr := schema.GroupVersionResource{

pkg/sidecar/proxy/data_parallel.go

@@ -11,7 +11,7 @@ import (
 
 	"github.com/llm-d/llm-d-inference-scheduler/pkg/common"
 	"golang.org/x/sync/errgroup"
-	"k8s.io/klog/v2"
+	"sigs.k8s.io/controller-runtime/pkg/log"
 )
 
 // dataParallelHandler checks if Data Parallel handling is needed.
@@ -71,7 +71,7 @@ func (s *Server) startDataParallel(ctx context.Context, cert *tls.Certificate, g
 			}
 
 			clone := s.Clone()
-			clone.logger = klog.FromContext(ctx).WithName("proxy server on port " + rankPort)
+			clone.logger = log.FromContext(ctx).WithName("proxy server on port " + rankPort)
 			clone.port = rankPort
 			clone.decoderURL = decoderURL
 			clone.forwardDataParallel = false

pkg/sidecar/proxy/proxy.go

@@ -29,7 +29,7 @@ import (
 	"github.com/go-logr/logr"
 	lru "github.com/hashicorp/golang-lru/v2"
 	"golang.org/x/sync/errgroup"
-	"k8s.io/klog/v2"
+	"sigs.k8s.io/controller-runtime/pkg/log"
 )
 
 const (
@@ -141,7 +141,7 @@ func NewProxy(port string, decodeURL *url.URL, config Config) *Server {
 
 // Start the HTTP reverse proxy.
 func (s *Server) Start(ctx context.Context, cert *tls.Certificate, allowlistValidator *AllowlistValidator) error {
-	s.logger = klog.FromContext(ctx).WithName("proxy server on port " + s.port)
+	s.logger = log.FromContext(ctx).WithName("proxy server on port " + s.port)
 
 	s.allowlistValidator = allowlistValidator