add more logging

Author: floreks

modules/common/client/cache/cache.go

@@ -32,6 +32,7 @@ func getCacheKey(token, key string) (string, error) {
 
 	contextKey, exists := contextCache.Get(token)
 	if exists {
+		klog.V(4).InfoS("context key found in cache", "key", contextKey)
 		return fmt.Sprintf("%s:%s", contextKey, key), nil
 	}
 
@@ -79,13 +80,14 @@ func DeferredLoad[T any](token, key string, loadFunc func() (T, error)) {
 
 		_, locked := cacheLocks.Load(cacheKey)
 		if locked {
-			// Skip.
+			klog.V(4).InfoS("cache is already being updated, skipping")
 			return
 		}
 
 		cacheLocks.Store(cacheKey, struct{}{})
 		defer time.AfterFunc(args.CacheRefreshDebounce(), func() {
 			cacheLocks.Delete(cacheKey)
+			klog.V(4).InfoS("released cache update lock")
 		})
 
 		cacheValue, err := loadFunc()
@@ -95,5 +97,6 @@ func DeferredLoad[T any](token, key string, loadFunc func() (T, error)) {
 		}
 
 		_ = cache.SetWithTTL(cacheKey, cacheValue, 1, args.CacheTTL())
+		klog.V(4).InfoS("cache updated successfully")
 	}()
 }

modules/common/client/cache/client.go renamed to modules/common/client/cache/httpclient.go

@@ -4,21 +4,23 @@ import (
 	"io"
 	"net/http"
 
+	"k8s.io/klog/v2"
+
 	"k8s.io/dashboard/client/args"
 )
 
-type TokenExchangeTransport struct {
+type tokenExchangeTransport struct {
 	token     string
 	transport http.RoundTripper
 }
 
-func (in *TokenExchangeTransport) RoundTrip(req *http.Request) (*http.Response, error) {
+func (in *tokenExchangeTransport) RoundTrip(req *http.Request) (*http.Response, error) {
 	req.Header.Set("Authorization", "Bearer "+in.token)
 	return in.transport.RoundTrip(req)
 }
 
 func exchangeToken(token string) (string, error) {
-	client := &http.Client{Transport: &TokenExchangeTransport{
+	client := &http.Client{Transport: &tokenExchangeTransport{
 		token:     token,
 		transport: http.DefaultTransport,
 	}}
@@ -34,5 +36,6 @@ func exchangeToken(token string) (string, error) {
 		return "", err
 	}
 
+	klog.V(3).InfoS("token exchange successful", "context", contextKey)
 	return string(contextKey), nil
 }

modules/common/client/verber.go

@@ -56,11 +56,11 @@ func (v *resourceVerber) groupVersionResourceFromUnstructured(object *unstructur
 
 func (v *resourceVerber) groupVersionResourceFromKind(kind string) (schema.GroupVersionResource, error) {
 	if gvr, exists := kindToGroupVersionResource[kind]; exists {
-		klog.V(3).InfoS("GroupVersionResource cache hit", "kind", kind)
+		klog.V(4).InfoS("GroupVersionResource cache hit", "kind", kind)
 		return gvr, nil
 	}
 
-	klog.V(3).InfoS("GroupVersionResource cache miss", "kind", kind)
+	klog.V(4).InfoS("GroupVersionResource cache miss", "kind", kind)
 	_, resourceList, err := v.discovery.ServerGroupsAndResources()
 	if err != nil {
 		return schema.GroupVersionResource{}, err
@@ -151,7 +151,7 @@ func (v *resourceVerber) Update(object *unstructured.Unstructured) error {
 	gvr := v.groupVersionResourceFromUnstructured(object)
 
 	return retry.RetryOnConflict(retry.DefaultRetry, func() error {
-		klog.V(2).InfoS("fetching latest resource version", "group", gvr.Group, "version", gvr.Version, "resource", gvr.Resource, "name", name, "namespace", namespace)
+		klog.V(4).InfoS("fetching latest resource version", "group", gvr.Group, "version", gvr.Version, "resource", gvr.Resource, "name", name, "namespace", namespace)
 		result, getErr := v.client.Resource(gvr).Namespace(namespace).Get(context.TODO(), name, metav1.GetOptions{})
 		if getErr != nil {
 			return fmt.Errorf("failed to get latest %s version: %w", gvr.Resource, getErr)
@@ -174,7 +174,7 @@ func (v *resourceVerber) Update(object *unstructured.Unstructured) error {
 			return fmt.Errorf("failed creating merge patch: %w", err)
 		}
 
-		klog.V(3).InfoS("patching resource", "group", gvr.Group, "version", gvr.Version, "resource", gvr.Resource, "name", name, "namespace", namespace, "patch", string(patchBytes))
+		klog.V(2).InfoS("patching resource", "group", gvr.Group, "version", gvr.Version, "resource", gvr.Resource, "name", name, "namespace", namespace, "patch", string(patchBytes))
 		_, updateErr := v.client.Resource(gvr).Namespace(namespace).Patch(context.TODO(), name, k8stypes.MergePatchType, patchBytes, metav1.PatchOptions{})
 		return updateErr
 	})