fixes go formatting

go fmt is the standard tool for ensuring Go code is canonically formatted
The changes in this commit are the result of running go fmt on all files
without other changes

There are no functional changes in this commit to prevent any confusion
from unified diffs or odd diff interpretations, especially when
fixed automatically by users with Go-aware editors.

Author: wilybrace

apis/cr/v1/common.go

@@ -58,11 +58,13 @@ type PgContainerResources struct {
 	LimitsCPU      string `json:"limitscpu"`
 }
 
-// CompletedStatus - 
+// CompletedStatus -
 const CompletedStatus = "completed"
-// InProgressStatus - 
+
+// InProgressStatus -
 const InProgressStatus = "in progress"
-// SubmittedStatus - 
+
+// SubmittedStatus -
 const SubmittedStatus = "submitted"
 
 // JobCompletedStatus ....

apiserver/failoverservice/failoverimpl.go

@@ -261,10 +261,10 @@ func preferredNode(nodes []string, targetNode string) bool {
 
 func checkAutofail(cluster *crv1.Pgcluster) error {
 	var err error
-	
+
 	if util.IsAutofailEnabled(cluster) {
 		return errors.New("autofail flag is set to true, manual failover requires autofail to be set to false, use pgo update to disable autofail.")
 	}
-	
+
 	return err
 }

apiserver/loadservice/loadimpl.go

@@ -48,7 +48,7 @@ type loadJobTemplateFields struct {
 	PVCName            string
 	SecurityContext    string
 	ContainerResources string
-	PGUserSecret	   string
+	PGUserSecret       string
 }
 
 type containerResourcesTemplateFields struct {

apiserver/pgouserservice/pgouserimpl.go

@@ -238,10 +238,10 @@ func UpdatePgouser(clientset *kubernetes.Clientset, updatedBy string, request *m
 		secret.Data[MAP_KEY_NAMESPACES] = []byte("")
 	}
 
-	log.Info("Updating secret for: " , request.PgouserName )
+	log.Info("Updating secret for: ", request.PgouserName)
 	err = kubeapi.UpdateSecret(clientset, secret, apiserver.PgoNamespace)
 	if err != nil {
-		log.Debug("Error updating pgouser secret: " , err.Error)
+		log.Debug("Error updating pgouser secret: ", err.Error)
 		resp.Status.Code = msgs.Error
 		resp.Status.Msg = err.Error()
 		return resp

apiserver/upgradeservice/upgradeimpl.go

@@ -113,7 +113,7 @@ func CreateUpgrade(request *msgs.CreateUpgradeRequest, ns string) msgs.CreateUpg
 			response.Status.Msg = clusterName + " is not a valid pgcluster"
 			return response
 		}
-		
+
 		//figure out what version we are upgrading to
 		imageToUpgradeTo := apiserver.Pgo.Cluster.CCPImageTag
 		if request.CCPImageTag != "" {

apiserver/userservice/userimpl.go

@@ -21,10 +21,10 @@ import (
 	"fmt"
 	kerrors "k8s.io/apimachinery/pkg/api/errors"
 	"math/rand"
+	"regexp"
 	"strconv"
 	"strings"
 	"time"
-	"regexp"
 
 	crv1 "github.com/crunchydata/postgres-operator/apis/cr/v1"
 	"github.com/crunchydata/postgres-operator/apiserver"
@@ -168,7 +168,7 @@ func UpdateUser(request *msgs.UpdateUserRequest, pgouser string) msgs.UpdateUser
 				}
 				log.Debugf("expiring user %s", request.Username)
 			}
-			
+
 			if request.Expired != "" {
 				results := callDB(info, d.ObjectMeta.Name, request.Expired)
 				if len(results) > 0 {
@@ -645,8 +645,6 @@ func CreateUser(request *msgs.CreateUserRequest, pgouser string) msgs.CreateUser
 	resp.Status.Msg = ""
 	resp.Results = make([]string, 0)
 
-	
-
 	getDefaults()
 
 	log.Debugf("createUser selector is ", request.Selector)

apiservermsgs/common.go

@@ -17,7 +17,6 @@ limitations under the License.
 
 import ()
 
-
 const PGO_VERSION = "4.1.0"
 
 // Ok status

apiservermsgs/usermsgs.go

@@ -21,23 +21,23 @@ import (
 
 // UpdateUserRequest ...
 type UpdateUserRequest struct {
-	Clusters        		[]string
-	Selector        		string
-	AllFlag         		bool
-	ExpireUser      		bool
-	Namespace       		string
-	PasswordAgeDays 		int
-	PasswordAgeDaysUpdate 	bool
-	Username        		string
-	Password        		string
-	DeleteUser      		string
-	ValidDays       		string
-	UserDBAccess    		string
-	AddUser         		string
-	Expired         		string
-	ManagedUser     		bool
-	ClientVersion   		string
-	PasswordLength  		int
+	Clusters              []string
+	Selector              string
+	AllFlag               bool
+	ExpireUser            bool
+	Namespace             string
+	PasswordAgeDays       int
+	PasswordAgeDaysUpdate bool
+	Username              string
+	Password              string
+	DeleteUser            string
+	ValidDays             string
+	UserDBAccess          string
+	AddUser               string
+	Expired               string
+	ManagedUser           bool
+	ClientVersion         string
+	PasswordLength        int
 }
 
 // DeleteUserRequest ...

config/pgoconfig.go

@@ -302,7 +302,7 @@ func (c *PgoConfig) Validate() error {
 			return errors.New(errPrefix + "Invalid PGBadgerPort: " + err.Error())
 		}
 	}
-        if c.Cluster.ExporterPort == "" {
+	if c.Cluster.ExporterPort == "" {
 		c.Cluster.ExporterPort = DEFAULT_EXPORTER_PORT
 		log.Infof("setting ExporterPort to default %s", c.Cluster.ExporterPort)
 	} else {
@@ -319,7 +319,6 @@ func (c *PgoConfig) Validate() error {
 		}
 	}
 
-
 	if c.Cluster.LogStatement != "" {
 		found := false
 		for _, v := range log_statement_values {
@@ -348,7 +347,7 @@ func (c *PgoConfig) Validate() error {
 	if c.Cluster.PrimaryNodeLabel != "" {
 		parts := strings.Split(c.Cluster.PrimaryNodeLabel, "=")
 		if len(parts) != 2 {
-			return errors.New(errPrefix+ "Cluster.PrimaryNodeLabel does not follow key=value format")
+			return errors.New(errPrefix + "Cluster.PrimaryNodeLabel does not follow key=value format")
 		}
 	}
 
@@ -480,12 +479,12 @@ func (c *PgoConfig) Validate() error {
 		return errors.New(errPrefix + "Cluster.User is required")
 	} else {
 		// validates that username can be used as the kubernetes secret name
-		// Must consist of lower case alphanumeric characters, 
+		// Must consist of lower case alphanumeric characters,
 		// '-' or '.', and must start and end with an alphanumeric character
-                errs := validation.IsDNS1123Subdomain(c.Cluster.User)
+		errs := validation.IsDNS1123Subdomain(c.Cluster.User)
 		if len(errs) > 0 {
 			var msg string
-			for i := range errs{
+			for i := range errs {
 				msg = msg + errs[i]
 			}
 			return errors.New(errPrefix + msg)

controller/jobcontroller.go

@@ -107,14 +107,14 @@ func (c *JobController) onUpdate(oldObj, newObj interface{}) {
 		log.Debugf("jobController onUpdate rmdata job succeeded")
 		publishDeleteClusterComplete(labels[config.LABEL_PG_CLUSTER], job.ObjectMeta.Labels[config.LABEL_PG_CLUSTER_IDENTIFIER],
 			job.ObjectMeta.Labels[config.LABEL_PGOUSER], job.ObjectMeta.Namespace)
-		
+
 		log.Debugf("jobController onUpdate rmdata job case")
-	
+
 		err = handleRmdata(job, c.JobClient, c.JobClientset, job.ObjectMeta.Namespace)
 		if err != nil {
 			log.Error(err)
 		}
-		
+
 		return
 	}