Fix misspellings caught by misspell

It's inevitable they get into the codebase, but it's good to clean
them up every once in awhile.

Author: Jonathan S. Katz

apiserver/clusterservice/clusterimpl.go

@@ -1297,7 +1297,7 @@ func getClusterParams(request *msgs.CreateClusterRequest, name string, userLabel
 	annotations := map[string]string{}
 	// store the default current primary value as an annotation
 	annotations[config.ANNOTATION_CURRENT_PRIMARY] = spec.Name
-	// store the inital deployment value, which will match the
+	// store the initial deployment value, which will match the
 	// cluster name initially
 	annotations[config.ANNOTATION_PRIMARY_DEPLOYMENT] = spec.Name
 

apiserver/pgbouncerservice/pgbouncerimpl.go

@@ -187,7 +187,7 @@ func DeletePgbouncer(request *msgs.DeletePgbouncerRequest, ns string) msgs.Delet
 			}
 		}
 
-		// Disable the pgBouncer Deploymnet, whcih means setting Replicas to 0
+		// Disable the pgBouncer Deploymnet, which means setting Replicas to 0
 		cluster.Spec.PgBouncer.Replicas = 0
 		// Set the MemoryLimit of pgBouncer to false as well, as this is the default
 		// setting

bin/pgo-backrest-repo-sync/pgo-backrest-repo-sync.sh

@@ -47,7 +47,7 @@ rsync_repo() {
 }
 
 # Use the aws cli sync command to sync files from a source location to a target
-# location.  The this inlcudes syncing files between who s3 locations,
+# location.  The this includes syncing files between who s3 locations,
 # syncing a local directory to s3, or syncing from s3 to a local directory.
 aws_sync_repo() {
 	export AWS_CA_BUNDLE="${PGBACKREST_REPO1_S3_CA_FILE}"

controller/configmap/configmapcontroller.go

@@ -94,7 +94,7 @@ func (c *Controller) RunWorker(stopCh <-chan struct{}, doneCh chan<- struct{}) {
 func (c *Controller) waitForShutdown(stopCh <-chan struct{}) {
 	<-stopCh
 	c.workqueue.ShutDown()
-	log.Debug("ConfigMap Contoller: recieved stop signal, worker queue told to shutdown")
+	log.Debug("ConfigMap Contoller: received stop signal, worker queue told to shutdown")
 }
 
 // ShutdownWorker shuts down the work queue
@@ -158,7 +158,7 @@ func (c *Controller) processNextWorkItem() bool {
 			key, err)
 	}
 
-	// Finally if no error has occured forget this item
+	// Finally if no error has occurred forget this item
 	c.workqueue.Forget(obj)
 
 	return true

controller/pgcluster/pgclustercontroller.go

@@ -85,7 +85,7 @@ func (c *Controller) RunWorker(stopCh <-chan struct{}, doneCh chan<- struct{}) {
 func (c *Controller) waitForShutdown(stopCh <-chan struct{}) {
 	<-stopCh
 	c.Queue.ShutDown()
-	log.Debug("pgcluster Contoller: recieved stop signal, worker queue told to shutdown")
+	log.Debug("pgcluster Contoller: received stop signal, worker queue told to shutdown")
 }
 
 func (c *Controller) processNextItem() bool {
@@ -145,7 +145,7 @@ func (c *Controller) processNextItem() bool {
 	clusteroperator.AddClusterBase(c.PgclusterClientset, c.PgclusterClient, &cluster, cluster.ObjectMeta.Namespace)
 
 	// Now scale the repo deployment only to ensure it is initialized prior to the primary DB.
-	// Once the repo is ready, the primary datbase deployment will then also be scaled to 1.
+	// Once the repo is ready, the primary database deployment will then also be scaled to 1.
 	clusterInfo, err := clusteroperator.ScaleClusterDeployments(c.PgclusterClientset,
 		cluster, 1, false, false, true, false)
 	if err != nil {

controller/pgreplica/pgreplicacontroller.go

@@ -57,7 +57,7 @@ func (c *Controller) RunWorker(stopCh <-chan struct{}, doneCh chan<- struct{}) {
 func (c *Controller) waitForShutdown(stopCh <-chan struct{}) {
 	<-stopCh
 	c.Queue.ShutDown()
-	log.Debug("pgreplica Contoller: recieved stop signal, worker queue told to shutdown")
+	log.Debug("pgreplica Contoller: received stop signal, worker queue told to shutdown")
 }
 
 func (c *Controller) processNextItem() bool {

controller/pgtask/pgtaskcontroller.go

@@ -61,7 +61,7 @@ func (c *Controller) RunWorker(stopCh <-chan struct{}, doneCh chan<- struct{}) {
 func (c *Controller) waitForShutdown(stopCh <-chan struct{}) {
 	<-stopCh
 	c.Queue.ShutDown()
-	log.Debug("pgtask Contoller: recieved stop signal, worker queue told to shutdown")
+	log.Debug("pgtask Contoller: received stop signal, worker queue told to shutdown")
 }
 
 func (c *Controller) processNextItem() bool {

controller/pod/podcontroller.go

@@ -144,7 +144,7 @@ func (c *Controller) onUpdate(oldObj, newObj interface{}) {
 // setCurrentPrimary checks whether the newly promoted primary value differs from the pgcluster's
 // current primary value. If different, patch the CRD's annotation to match the new value
 func setCurrentPrimary(restclient *rest.RESTClient, newPod *apiv1.Pod, cluster *crv1.Pgcluster) {
-	// if a failover has occured and the current primary has changed, update the pgcluster CRD's annotation accordingly
+	// if a failover has occurred and the current primary has changed, update the pgcluster CRD's annotation accordingly
 	if cluster.Annotations[config.ANNOTATION_CURRENT_PRIMARY] != newPod.ObjectMeta.Labels[config.LABEL_DEPLOYMENT_NAME] {
 		err := util.CurrentPrimaryUpdate(restclient, cluster, newPod.ObjectMeta.Labels[config.LABEL_DEPLOYMENT_NAME], newPod.Namespace)
 		if err != nil {

operator/cluster/upgrade.go

@@ -250,7 +250,7 @@ func getCurrentPrimary(clusterName, podPrimary, crPrimary, labelPrimary string)
 	return clusterName
 }
 
-// handleReplicas deletes all pgreplicas related to the pgcluster to be ugpraded, then returns the number
+// handleReplicas deletes all pgreplicas related to the pgcluster to be upgraded, then returns the number
 // of pgreplicas that were found. This will delete any PVCs that match the existing pgreplica CRs, but
 // will leave any other PVCs, whether they are from the current primary, previous primaries that are now
 // unassociated because of a failover or the backrest-shared-repo PVC. The total number of current replicas
@@ -349,7 +349,7 @@ func deleteBeforeUpgrade(clientset *kubernetes.Clientset, restclient *rest.RESTC
 }
 
 // deploymentWait is modified from cluster.waitForDeploymentDelete. It simply waits for the current primary deployment
-// deletion to complete before proceding with the rest of the pgcluster upgrade.
+// deletion to complete before proceeding with the rest of the pgcluster upgrade.
 func deploymentWait(clientset *kubernetes.Clientset, namespace, deploymentName string, timeoutSecs, periodSecs time.Duration) string {
 	timeout := time.After(timeoutSecs * time.Second)
 	tick := time.Tick(periodSecs * time.Second)

operator/common.go

@@ -228,7 +228,7 @@ func initializeContainerImageOverrides() {
 }
 
 // initControllerRefreshIntervals initializes the refresh intervals for any informers
-// created by the Operator requiring a refresh interval.  This inlcudes first attempting
+// created by the Operator requiring a refresh interval.  This includes first attempting
 // to utilize the refresh interval(s) defined in the pgo.yaml config file, and if not
 // present then falling back to a default value.
 func initializeControllerRefreshIntervals() {
@@ -256,7 +256,7 @@ func initializeControllerRefreshIntervals() {
 }
 
 // initControllerWorkerCounts sets the number of workers that will be created for any worker
-// queues created within the various controllers created by the Operator.  This inlcudes first
+// queues created within the various controllers created by the Operator.  This includes first
 // attempting to utilize the worker counts defined in the pgo.yaml config file, and if not
 // present then falling back to a default value.
 func initializeControllerWorkerCounts() {