Fix the abbreviation for manager

The former abbreviation (`mrg`) is a well known typo.
This fixes instances of `mrg` so they say `mgr` (ManaGeR).

Author: DirectXMan12

example/main.go

@@ -47,15 +47,15 @@ func main() {
 	entryLog := log.WithName("entrypoint")
 
 	// Setup a Manager
-	mrg, err := manager.New(config.GetConfigOrDie(), manager.Options{})
+	mgr, err := manager.New(config.GetConfigOrDie(), manager.Options{})
 	if err != nil {
 		entryLog.Error(err, "unable to set up overall controller manager")
 		os.Exit(1)
 	}
 
 	// Setup a new controller to Reconciler ReplicaSets
-	c, err := controller.New("foo-controller", mrg, controller.Options{
-		Reconciler: &reconcileReplicaSet{client: mrg.GetClient(), log: log.WithName("reconciler")},
+	c, err := controller.New("foo-controller", mgr, controller.Options{
+		Reconciler: &reconcileReplicaSet{client: mgr.GetClient(), log: log.WithName("reconciler")},
 	})
 	if err != nil {
 		entryLog.Error(err, "unable to set up individual controller")
@@ -75,7 +75,7 @@ func main() {
 		os.Exit(1)
 	}
 
-	if err := mrg.Start(signals.SetupSignalHandler()); err != nil {
+	if err := mgr.Start(signals.SetupSignalHandler()); err != nil {
 		entryLog.Error(err, "unable to run manager")
 		os.Exit(1)
 	}

pkg/controller/example_test.go

@@ -28,12 +28,12 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/source"
 )
 
-var mrg manager.Manager
+var mgr manager.Manager
 
 // This example creates a new Controller named "pod-controller" with a no-op reconcile function.  The
 // manager.Manager will be used to Start the Controller, and will provide it a shared Cache and Client.
 func ExampleNew() {
-	_, err := controller.New("pod-controller", mrg, controller.Options{
+	_, err := controller.New("pod-controller", mgr, controller.Options{
 		Reconciler: reconcile.Func(func(o reconcile.Request) (reconcile.Result, error) {
 			// Your business logic to implement the API by creating, updating, deleting objects goes here.
 			return reconcile.Result{}, nil
@@ -46,11 +46,11 @@ func ExampleNew() {
 
 // This example starts a new Controller named "pod-controller" to Watch Pods and call a no-op Reconciler.
 func ExampleController() {
-	// mrg is a manager.Manager
+	// mgr is a manager.Manager
 
 	// Create a new Controller that will call the provided Reconciler function in response
 	// to events.
-	c, err := controller.New("pod-controller", mrg, controller.Options{
+	c, err := controller.New("pod-controller", mgr, controller.Options{
 		Reconciler: reconcile.Func(func(o reconcile.Request) (reconcile.Result, error) {
 			// Your business logic to implement the API by creating, updating, deleting objects goes here.
 			return reconcile.Result{}, nil
@@ -70,5 +70,5 @@ func ExampleController() {
 	}
 
 	// Start the Controller through the manager.
-	mrg.Start(signals.SetupSignalHandler())
+	mgr.Start(signals.SetupSignalHandler())
 }

pkg/manager/example_test.go

@@ -24,7 +24,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/runtime/signals"
 )
 
-var mrg manager.Manager
+var mgr manager.Manager
 
 // This example creates a new Manager that can be used with controller.New to create Controllers.
 func ExampleNew() {
@@ -33,16 +33,16 @@ func ExampleNew() {
 		log.Fatal(err)
 	}
 
-	mrg, err := manager.New(cfg, manager.Options{})
+	mgr, err := manager.New(cfg, manager.Options{})
 	if err != nil {
 		log.Fatal(err)
 	}
-	log.Print(mrg)
+	log.Print(mgr)
 }
 
 // This example adds a Runnable for the Manager to Start.
 func ExampleManager_Add() {
-	err := mrg.Add(manager.RunnableFunc(func(<-chan struct{}) error {
+	err := mgr.Add(manager.RunnableFunc(func(<-chan struct{}) error {
 		// Do something
 		return nil
 	}))
@@ -53,7 +53,7 @@ func ExampleManager_Add() {
 
 // This example starts a Manager that has had Runnables added.
 func ExampleManager_Start() {
-	err := mrg.Start(signals.SetupSignalHandler())
+	err := mgr.Start(signals.SetupSignalHandler())
 	if err != nil {
 		log.Fatal(err)
 	}

pkg/manager/manager_test.go

@@ -138,9 +138,9 @@ var _ = Describe("manger.Manager", func() {
 		It("should return an error if it can't start the cache", func(done Done) {
 			m, err := New(cfg, Options{})
 			Expect(err).NotTo(HaveOccurred())
-			mrg, ok := m.(*controllerManager)
+			mgr, ok := m.(*controllerManager)
 			Expect(ok).To(BeTrue())
-			mrg.startCache = func(stop <-chan struct{}) error {
+			mgr.startCache = func(stop <-chan struct{}) error {
 				return fmt.Errorf("expected error")
 			}
 			Expect(m.Start(stop).Error()).To(ContainSubstring("expected error"))
@@ -188,7 +188,7 @@ var _ = Describe("manger.Manager", func() {
 			func(done Done) {
 				m, err := New(cfg, Options{})
 				Expect(err).NotTo(HaveOccurred())
-				mrg, ok := m.(*controllerManager)
+				mgr, ok := m.(*controllerManager)
 				Expect(ok).To(BeTrue())
 
 				// Add one component before starting
@@ -205,7 +205,7 @@ var _ = Describe("manger.Manager", func() {
 				}()
 
 				// Wait for the Manager to start
-				Eventually(func() bool { return mrg.started }).Should(BeTrue())
+				Eventually(func() bool { return mgr.started }).Should(BeTrue())
 
 				// Add another component after starting
 				c2 := make(chan struct{})
@@ -223,7 +223,7 @@ var _ = Describe("manger.Manager", func() {
 		It("should immediately start the Component if the Manager has already Started", func(done Done) {
 			m, err := New(cfg, Options{})
 			Expect(err).NotTo(HaveOccurred())
-			mrg, ok := m.(*controllerManager)
+			mgr, ok := m.(*controllerManager)
 			Expect(ok).To(BeTrue())
 
 			go func() {
@@ -232,7 +232,7 @@ var _ = Describe("manger.Manager", func() {
 			}()
 
 			// Wait for the Manager to start
-			Eventually(func() bool { return mrg.started }).Should(BeTrue())
+			Eventually(func() bool { return mgr.started }).Should(BeTrue())
 
 			c1 := make(chan struct{})
 			m.Add(RunnableFunc(func(s <-chan struct{}) error {
@@ -255,10 +255,10 @@ var _ = Describe("manger.Manager", func() {
 		It("should inject field values", func(done Done) {
 			m, err := New(cfg, Options{})
 			Expect(err).NotTo(HaveOccurred())
-			mrg, ok := m.(*controllerManager)
+			mgr, ok := m.(*controllerManager)
 			Expect(ok).To(BeTrue())
 
-			mrg.cache = &informertest.FakeInformers{}
+			mgr.cache = &informertest.FakeInformers{}
 
 			By("Injecting the dependencies")
 			err = m.SetFields(&injectable{
@@ -346,33 +346,33 @@ var _ = Describe("manger.Manager", func() {
 	It("should provide a function to get the Config", func() {
 		m, err := New(cfg, Options{})
 		Expect(err).NotTo(HaveOccurred())
-		mrg, ok := m.(*controllerManager)
+		mgr, ok := m.(*controllerManager)
 		Expect(ok).To(BeTrue())
-		Expect(m.GetConfig()).To(Equal(mrg.config))
+		Expect(m.GetConfig()).To(Equal(mgr.config))
 	})
 
 	It("should provide a function to get the Client", func() {
 		m, err := New(cfg, Options{})
 		Expect(err).NotTo(HaveOccurred())
-		mrg, ok := m.(*controllerManager)
+		mgr, ok := m.(*controllerManager)
 		Expect(ok).To(BeTrue())
-		Expect(m.GetClient()).To(Equal(mrg.client))
+		Expect(m.GetClient()).To(Equal(mgr.client))
 	})
 
 	It("should provide a function to get the Scheme", func() {
 		m, err := New(cfg, Options{})
 		Expect(err).NotTo(HaveOccurred())
-		mrg, ok := m.(*controllerManager)
+		mgr, ok := m.(*controllerManager)
 		Expect(ok).To(BeTrue())
-		Expect(m.GetScheme()).To(Equal(mrg.scheme))
+		Expect(m.GetScheme()).To(Equal(mgr.scheme))
 	})
 
 	It("should provide a function to get the FieldIndexer", func() {
 		m, err := New(cfg, Options{})
 		Expect(err).NotTo(HaveOccurred())
-		mrg, ok := m.(*controllerManager)
+		mgr, ok := m.(*controllerManager)
 		Expect(ok).To(BeTrue())
-		Expect(m.GetFieldIndexer()).To(Equal(mrg.fieldIndexes))
+		Expect(m.GetFieldIndexer()).To(Equal(mgr.fieldIndexes))
 	})
 
 	It("should provide a function to get the EventRecorder", func() {