fmt

Author: godwinpang

pkg/controller/controller.go

@@ -131,9 +131,9 @@ func (options *TypedOptions[request]) DefaultFromConfig(config config.Controller
 		options.NeedLeaderElection = config.NeedLeaderElection
 	}
 
-    if options.NeedWarmup == nil {
-        options.NeedWarmup = config.NeedWarmup
-    }
+	if options.NeedWarmup == nil {
+		options.NeedWarmup = config.NeedWarmup
+	}
 }
 
 // Controller implements an API. A Controller manages a work queue fed reconcile.Requests
@@ -254,16 +254,16 @@ func NewTypedUnmanaged[request comparable](name string, options TypedOptions[req
 
 	// Create controller with dependencies set
 	return &controller.Controller[request]{
-		Do:                            options.Reconciler,
-		RateLimiter:                   options.RateLimiter,
-		NewQueue:                      options.NewQueue,
-		MaxConcurrentReconciles:       options.MaxConcurrentReconciles,
-		CacheSyncTimeout:              options.CacheSyncTimeout,
-		Name:                          name,
-		LogConstructor:                options.LogConstructor,
-		RecoverPanic:                  options.RecoverPanic,
-		LeaderElected:                 options.NeedLeaderElection,
-		NeedWarmup:                    options.NeedWarmup,
+		Do:                      options.Reconciler,
+		RateLimiter:             options.RateLimiter,
+		NewQueue:                options.NewQueue,
+		MaxConcurrentReconciles: options.MaxConcurrentReconciles,
+		CacheSyncTimeout:        options.CacheSyncTimeout,
+		Name:                    name,
+		LogConstructor:          options.LogConstructor,
+		RecoverPanic:            options.RecoverPanic,
+		LeaderElected:           options.NeedLeaderElection,
+		NeedWarmup:              options.NeedWarmup,
 	}, nil
 }
 

pkg/controller/controller_test.go

@@ -481,7 +481,7 @@ var _ = Describe("controller.Controller", func() {
 
 			// Test with ShouldWarmupWithoutLeadership set to true
 			ctrlWithWarmup, err := controller.New("warmup-enabled-ctrl", m, controller.Options{
-				Reconciler:                    reconcile.Func(nil),
+				Reconciler: reconcile.Func(nil),
 				NeedWarmup: ptr.To(true),
 			})
 			Expect(err).NotTo(HaveOccurred())
@@ -493,7 +493,7 @@ var _ = Describe("controller.Controller", func() {
 
 			// Test with ShouldWarmupWithoutLeadership set to false
 			ctrlWithoutWarmup, err := controller.New("warmup-disabled-ctrl", m, controller.Options{
-				Reconciler:                    reconcile.Func(nil),
+				Reconciler: reconcile.Func(nil),
 				NeedWarmup: ptr.To(false),
 			})
 			Expect(err).NotTo(HaveOccurred())
@@ -534,7 +534,7 @@ var _ = Describe("controller.Controller", func() {
 
 			// Test that explicit controller setting overrides manager setting
 			ctrlOverridingWarmup, err := controller.New("override-warmup-disabled", managerWithWarmup, controller.Options{
-				Reconciler:                    reconcile.Func(nil),
+				Reconciler: reconcile.Func(nil),
 				NeedWarmup: ptr.To(false),
 			})
 			Expect(err).NotTo(HaveOccurred())

pkg/manager/runnable_group.go

@@ -230,16 +230,16 @@ func (r *runnableGroup) reconcile() {
 				}
 			}()
 
-            // If we return, the runnable ended cleanly
+			// If we return, the runnable ended cleanly
 			// or returned an error to the channel.
 			//
 			// We should always decrement the WaitGroup here.
 			defer r.wg.Done()
 
 			// Start the runnable.
-            if err := rn.Start(r.ctx); err != nil {
-                r.errChan <- err
-            }
+			if err := rn.Start(r.ctx); err != nil {
+				r.errChan <- err
+			}
 		}(runnable)
 	}
 }
@@ -297,7 +297,7 @@ func (r *runnableGroup) Add(rn Runnable, ready runnableCheck) error {
 // StopAndWait waits for all the runnables to finish before returning.
 func (r *runnableGroup) StopAndWait(ctx context.Context) {
 	r.stopOnce.Do(func() {
-        // Close the reconciler channel once we're done.
+		// Close the reconciler channel once we're done.
 		defer func() {
 			r.stop.Lock()
 			close(r.ch)