Improve log k/v pairs and a improve/drop a few log lines

bootstrap/kubeadm/internal/controllers/kubeadmconfig_controller.go

@@ -147,14 +147,6 @@ func (r *KubeadmConfigReconciler) Reconcile(ctx context.Context, req ctrl.Reques
 		if apierrors.IsNotFound(err) {
 			return ctrl.Result{}, nil
 		}
-		log.Error(err, "Failed to get config")
-		return ctrl.Result{}, err
-	}
-
-	// AddOwners adds the owners of KubeadmConfig as k/v pairs to the logger.
-	// Specifically, it will add KubeadmControlPlane, MachineSet and MachineDeployment.
-	ctx, log, err := clog.AddOwners(ctx, r.Client, config)
-	if err != nil {
 		return ctrl.Result{}, err
 	}
 
@@ -165,13 +157,22 @@ func (r *KubeadmConfigReconciler) Reconcile(ctx context.Context, req ctrl.Reques
 		return ctrl.Result{}, nil
 	}
 	if err != nil {
-		log.Error(err, "Failed to get owner")
-		return ctrl.Result{}, err
+		return ctrl.Result{}, errors.Wrapf(err, "failed to get owner")
 	}
 	if configOwner == nil {
 		return ctrl.Result{}, nil
 	}
 	log = log.WithValues(configOwner.GetKind(), klog.KRef(configOwner.GetNamespace(), configOwner.GetName()), "resourceVersion", configOwner.GetResourceVersion())
+	ctx = ctrl.LoggerInto(ctx, log)
+
+	if configOwner.GetKind() == "Machine" {
+		// AddOwners adds the owners of Machine as k/v pairs to the logger.
+		// Specifically, it will add KubeadmControlPlane, MachineSet and MachineDeployment.
+		ctx, log, err = clog.AddOwners(ctx, r.Client, configOwner)
+		if err != nil {
+			return ctrl.Result{}, err
+		}
+	}
 
 	log = log.WithValues("Cluster", klog.KRef(configOwner.GetNamespace(), configOwner.ClusterName()))
 	ctx = ctrl.LoggerInto(ctx, log)
@@ -1043,7 +1044,7 @@ func (r *KubeadmConfigReconciler) storeBootstrapData(ctx context.Context, scope
 		if !apierrors.IsAlreadyExists(err) {
 			return errors.Wrapf(err, "failed to create bootstrap data secret for KubeadmConfig %s/%s", scope.Config.Namespace, scope.Config.Name)
 		}
-		log.Info("bootstrap data secret for KubeadmConfig already exists, updating", "Secret", klog.KObj(secret))
+		log.Info("Bootstrap data secret for KubeadmConfig already exists, updating", "Secret", klog.KObj(secret))
 		if err := r.Client.Update(ctx, secret); err != nil {
 			return errors.Wrapf(err, "failed to update bootstrap data secret for KubeadmConfig %s/%s", scope.Config.Namespace, scope.Config.Name)
 		}

bootstrap/kubeadm/main.go

@@ -294,13 +294,12 @@ func setupReconcilers(ctx context.Context, mgr ctrl.Manager) {
 
 	// Set up a ClusterCacheTracker and ClusterCacheReconciler to provide to controllers
 	// requiring a connection to a remote cluster
-	log := ctrl.Log.WithName("remote").WithName("ClusterCacheTracker")
 	tracker, err := remote.NewClusterCacheTracker(
 		mgr,
 		remote.ClusterCacheTrackerOptions{
 			SecretCachingClient: secretCachingClient,
 			ControllerName:      controllerName,
-			Log:                 &log,
+			Log:                 &ctrl.Log,
 		},
 	)
 	if err != nil {

controllers/remote/cluster_cache_tracker.go

@@ -129,6 +129,9 @@ func setDefaultOptions(opts *ClusterCacheTrackerOptions) {
 		opts.Log = &l
 	}
 
+	l := opts.Log.WithValues("component", "remote/clustercachetracker")
+	opts.Log = &l
+
 	if len(opts.ClientUncachedObjects) == 0 {
 		opts.ClientUncachedObjects = []client.Object{
 			&corev1.ConfigMap{},

controlplane/kubeadm/main.go

@@ -302,11 +302,10 @@ func setupReconcilers(ctx context.Context, mgr ctrl.Manager) {
 
 	// Set up a ClusterCacheTracker to provide to controllers
 	// requiring a connection to a remote cluster
-	log := ctrl.Log.WithName("remote").WithName("ClusterCacheTracker")
 	tracker, err := remote.NewClusterCacheTracker(mgr, remote.ClusterCacheTrackerOptions{
 		SecretCachingClient: secretCachingClient,
 		ControllerName:      controllerName,
-		Log:                 &log,
+		Log:                 &ctrl.Log,
 		ClientUncachedObjects: []client.Object{
 			&corev1.ConfigMap{},
 			&corev1.Secret{},

docs/book/src/tasks/experimental-features/runtime-sdk/implement-extensions.md

@@ -89,7 +89,7 @@ func InitFlags(fs *pflag.FlagSet) {
 
 func main() {
 	// Creates a logger to be used during the main func.
-	setupLog := ctrl.Log.WithName("main")
+	setupLog := ctrl.Log.WithName("setup")
 
 	// Initialize and parse command line flags.
 	InitFlags(pflag.CommandLine)

internal/controllers/cluster/suite_test.go

@@ -64,11 +64,10 @@ func TestMain(m *testing.M) {
 	setupReconcilers := func(ctx context.Context, mgr ctrl.Manager) {
 		// Set up a ClusterCacheTracker and ClusterCacheReconciler to provide to controllers
 		// requiring a connection to a remote cluster
-		log := ctrl.Log.WithName("remote").WithName("ClusterCacheTracker")
 		tracker, err := remote.NewClusterCacheTracker(
 			mgr,
 			remote.ClusterCacheTrackerOptions{
-				Log:     &log,
+				Log:     &ctrl.Log,
 				Indexes: []remote.Index{remote.NodeProviderIDIndex},
 			},
 		)

internal/controllers/machine/suite_test.go

@@ -69,11 +69,10 @@ func TestMain(m *testing.M) {
 	setupReconcilers := func(ctx context.Context, mgr ctrl.Manager) {
 		// Set up a ClusterCacheTracker and ClusterCacheReconciler to provide to controllers
 		// requiring a connection to a remote cluster
-		log := ctrl.Log.WithName("remote").WithName("ClusterCacheTracker")
 		tracker, err := remote.NewClusterCacheTracker(
 			mgr,
 			remote.ClusterCacheTrackerOptions{
-				Log:     &log,
+				Log:     &ctrl.Log,
 				Indexes: []remote.Index{remote.NodeProviderIDIndex},
 			},
 		)

internal/controllers/machinedeployment/machinedeployment_controller.go

@@ -164,7 +164,6 @@ func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Re
 
 	err = r.reconcile(ctx, cluster, deployment)
 	if err != nil {
-		log.Error(err, "Failed to reconcile MachineDeployment")
 		r.recorder.Eventf(deployment, corev1.EventTypeWarning, "ReconcileError", "%v", err)
 	}
 	return ctrl.Result{}, err

internal/controllers/machinedeployment/suite_test.go

@@ -71,11 +71,10 @@ func TestMain(m *testing.M) {
 	setupReconcilers := func(ctx context.Context, mgr ctrl.Manager) {
 		// Set up a ClusterCacheTracker and ClusterCacheReconciler to provide to controllers
 		// requiring a connection to a remote cluster
-		log := ctrl.Log.WithName("remote").WithName("ClusterCacheTracker")
 		tracker, err := remote.NewClusterCacheTracker(
 			mgr,
 			remote.ClusterCacheTrackerOptions{
-				Log:     &log,
+				Log:     &ctrl.Log,
 				Indexes: []remote.Index{remote.NodeProviderIDIndex},
 			},
 		)

internal/controllers/machinehealthcheck/suite_test.go

@@ -67,11 +67,10 @@ func TestMain(m *testing.M) {
 	setupReconcilers := func(ctx context.Context, mgr ctrl.Manager) {
 		// Set up a ClusterCacheTracker and ClusterCacheReconciler to provide to controllers
 		// requiring a connection to a remote cluster
-		log := ctrl.Log.WithName("remote").WithName("ClusterCacheTracker")
 		tracker, err := remote.NewClusterCacheTracker(
 			mgr,
 			remote.ClusterCacheTrackerOptions{
-				Log:     &log,
+				Log:     &ctrl.Log,
 				Indexes: []remote.Index{remote.NodeProviderIDIndex},
 			},
 		)

internal/controllers/machineset/machineset_controller.go

@@ -890,7 +890,7 @@ func (r *Reconciler) updateStatus(ctx context.Context, cluster *clusterv1.Cluste
 				availableReplicasCount++
 			}
 		} else if machine.GetDeletionTimestamp().IsZero() {
-			log.Info("Waiting for the Kubernetes node on the machine to report ready state")
+			log.V(4).Info("Waiting for the Kubernetes node on the machine to report ready state")
 		}
 	}
 

internal/controllers/machineset/suite_test.go

@@ -70,11 +70,10 @@ func TestMain(m *testing.M) {
 	setupReconcilers := func(ctx context.Context, mgr ctrl.Manager) {
 		// Set up a ClusterCacheTracker and ClusterCacheReconciler to provide to controllers
 		// requiring a connection to a remote cluster
-		log := ctrl.Log.WithName("remote").WithName("ClusterCacheTracker")
 		tracker, err := remote.NewClusterCacheTracker(
 			mgr,
 			remote.ClusterCacheTrackerOptions{
-				Log:     &log,
+				Log:     &ctrl.Log,
 				Indexes: []remote.Index{remote.NodeProviderIDIndex},
 			},
 		)

internal/controllers/topology/cluster/suite_test.go

@@ -76,7 +76,6 @@ func TestMain(m *testing.M) {
 		}
 		// Set up a ClusterCacheTracker and ClusterCacheReconciler to provide to controllers
 		// requiring a connection to a remote cluster
-		log := ctrl.Log.WithName("remote").WithName("ClusterCacheTracker")
 		secretCachingClient, err := client.New(mgr.GetConfig(), client.Options{
 			HTTPClient: mgr.GetHTTPClient(),
 			Cache: &client.CacheOptions{
@@ -89,7 +88,7 @@ func TestMain(m *testing.M) {
 		tracker, err := remote.NewClusterCacheTracker(
 			mgr,
 			remote.ClusterCacheTrackerOptions{
-				Log:                 &log,
+				Log:                 &ctrl.Log,
 				SecretCachingClient: secretCachingClient,
 			},
 		)

main.go

@@ -380,13 +380,12 @@ func setupReconcilers(ctx context.Context, mgr ctrl.Manager) {
 
 	// Set up a ClusterCacheTracker and ClusterCacheReconciler to provide to controllers
 	// requiring a connection to a remote cluster
-	log := ctrl.Log.WithName("remote").WithName("ClusterCacheTracker")
 	tracker, err := remote.NewClusterCacheTracker(
 		mgr,
 		remote.ClusterCacheTrackerOptions{
 			SecretCachingClient: secretCachingClient,
 			ControllerName:      controllerName,
-			Log:                 &log,
+			Log:                 &ctrl.Log,
 			Indexes:             []remote.Index{remote.NodeProviderIDIndex},
 		},
 	)

test/infrastructure/docker/main.go

@@ -303,13 +303,12 @@ func setupReconcilers(ctx context.Context, mgr ctrl.Manager) {
 		os.Exit(1)
 	}
 
-	log := ctrl.Log.WithName("remote").WithName("ClusterCacheTracker")
 	tracker, err := remote.NewClusterCacheTracker(
 		mgr,
 		remote.ClusterCacheTrackerOptions{
 			SecretCachingClient: secretCachingClient,
 			ControllerName:      controllerName,
-			Log:                 &log,
+			Log:                 &ctrl.Log,
 		},
 	)
 	if err != nil {