go fmt project

Author: gbolo

common/funcs.go

@@ -19,4 +19,4 @@ func GetMD5Hash(text string) string {
 func ExecutionTime(start time.Time, name string) {
 	elapsed := time.Since(start)
 	log.Debugf("%s took %s", name, elapsed)
-}
+}

config/config.go

@@ -1,10 +1,11 @@
 package config
 
 import (
-	"github.com/spf13/viper"
-	"strings"
-	"os"
 	"fmt"
+	"os"
+	"strings"
+
+	"github.com/spf13/viper"
 )
 
 func ConfigInit(cfgFile string) {
@@ -74,22 +75,22 @@ func printConfigSummary() {
 		"server.bind_port",
 		"backend.db_driver",
 		"backend.db_dsn",
-		} {
+	} {
 
 		log.Debugf("%s: %s\n", c, viper.GetString(c))
 	}
 }
 
 func sanityChecks() {
 
-	if viper.GetString("backend.db_driver") != "mysql" && viper.GetString("backend.db_driver") != ""  {
+	if viper.GetString("backend.db_driver") != "mysql" && viper.GetString("backend.db_driver") != "" {
 
 		log.Fatalf("only mysql is supported for backend_db_driver (value: %s)", viper.GetString("backend.db_driver"))
 	}
 
-	if viper.GetString("backend.db_dsn") == ""  {
+	if viper.GetString("backend.db_dsn") == "" {
 
 		log.Fatal("backend_db_dsn must be set")
 	}
 
-}
+}

config/logger.go

@@ -1,8 +1,9 @@
 package config
 
 import (
-	"github.com/op/go-logging"
 	"os"
+
+	"github.com/op/go-logging"
 )
 
 var log = logging.MustGetLogger("vsummary")
@@ -12,7 +13,6 @@ func loggingInit(loglevel string) {
 	// In case of an invalid log level we default to ERROR
 	var log_level logging.Level = logging.ERROR
 
-
 	// Validating log levels
 	_, err := logging.LogLevel(loglevel)
 	if err != nil {
@@ -46,4 +46,4 @@ func loggingInit(loglevel string) {
 	log_backend_fl.SetLevel(log_level, "")
 
 	logging.SetBackend(log_backend_fl)
-}
+}

crypto/aes.go

@@ -100,4 +100,4 @@ func Decrypt(cryptoText string) (decryptedText string, err error) {
 	decryptedText = fmt.Sprintf("%s", ciphertext)
 
 	return
-}
+}

db/selects.go

@@ -1,7 +1,6 @@
 package db
 
 import (
-
 	"github.com/gbolo/vsummary/common"
 )
 
@@ -23,4 +22,3 @@ func (b *Backend) GetPollers() (pollers []common.Poller, err error) {
 	return
 
 }
-

main.go

@@ -1,13 +1,12 @@
 package main
 
 import (
-
 	_ "github.com/go-sql-driver/mysql"
 	//"github.com/jmoiron/sqlx"
+	"github.com/gbolo/vsummary/config"
 	back "github.com/gbolo/vsummary/db"
 	"github.com/gbolo/vsummary/poller"
 	"github.com/gbolo/vsummary/server"
-	"github.com/gbolo/vsummary/config"
 	//"github.com/gbolo/vsummary/crypto"
 
 	//"context"
@@ -17,8 +16,8 @@ import (
 
 	"crypto/md5"
 	"encoding/hex"
-	"github.com/op/go-logging"
 	"fmt"
+	"github.com/op/go-logging"
 	//"net/http"
 	"time"
 	//"os"
@@ -50,8 +49,6 @@ func main() {
 	pollers, err := b.GetPollers()
 	fmt.Println(pollers)
 
-
-
 	//// vmware section ----------------------------------------------------------------------
 	//ctx, cancel := context.WithCancel(context.Background())
 	//defer cancel()
@@ -75,7 +72,6 @@ func main() {
 
 	go server.Start()
 
-
 	time.Sleep(3 * time.Second)
 
 	fmt.Println("---------------------------------------------------------------------------------------")
@@ -90,4 +86,4 @@ func GetMD5Hash(text string) string {
 	hasher := md5.New()
 	hasher.Write([]byte(text))
 	return hex.EncodeToString(hasher.Sum(nil))
-}
+}

poller/client.go

@@ -1,13 +1,14 @@
 package poller
 
 import (
-	"net/http"
-	"time"
-	"fmt"
-	"github.com/spf13/viper"
 	"bytes"
+	"fmt"
 	"io"
 	"io/ioutil"
+	"net/http"
+	"time"
+
+	"github.com/spf13/viper"
 )
 
 var vSummaryClient *http.Client
@@ -52,7 +53,7 @@ func sendResults(endpoint string, jsonBody []byte) (err error) {
 	// send request
 	log.Debugf("sending results to: %s", url)
 	//log.Debugf("jsonBody: %s", string(jsonBody))
-	res, err := vSummaryClient.Post(url,"application/json", bytes.NewReader(jsonBody))
+	res, err := vSummaryClient.Post(url, "application/json", bytes.NewReader(jsonBody))
 
 	// this means the vsummary server api is unreachable
 	if err != nil {
@@ -74,4 +75,4 @@ func sendResults(endpoint string, jsonBody []byte) (err error) {
 
 	log.Infof("api call successful: %d %s", res.StatusCode, url)
 	return
-}
+}

poller/load.go

@@ -68,4 +68,4 @@ func pollerLoop(p *Poller) (err error) {
 		}
 	}
 
-}
+}

poller/poll_datacenters.go

@@ -2,18 +2,14 @@ package poller
 
 import (
 	"context"
-	//"encoding/json"
+	"encoding/json"
 	"time"
 
 	"github.com/gbolo/vsummary/common"
 	"github.com/vmware/govmomi/view"
 	"github.com/vmware/govmomi/vim25/mo"
-	//"github.com/vmware/govmomi/govc/datacenter"
-	"encoding/json"
 )
 
-
-
 func (p *Poller) GetDatacenters() (dcList []common.Datacenter, err error) {
 
 	// log time on debug
@@ -48,11 +44,11 @@ func (p *Poller) GetDatacenters() (dcList []common.Datacenter, err error) {
 	for _, dc := range dcs {
 
 		dcStruct := common.Datacenter{
-			Name:                 dc.Name,
-			Moref:                dc.Self.Value,
-			EsxiFolderMoref:	  dc.HostFolder.Value,
-			VmFolderMoref:		  dc.VmFolder.Value,
-			VcenterId:            v.Client().ServiceContent.About.InstanceUuid,
+			Name:            dc.Name,
+			Moref:           dc.Self.Value,
+			EsxiFolderMoref: dc.HostFolder.Value,
+			VmFolderMoref:   dc.VmFolder.Value,
+			VcenterId:       v.Client().ServiceContent.About.InstanceUuid,
 		}
 
 		dcList = append(dcList, dcStruct)

poller/poll_vms.go

@@ -10,8 +10,6 @@ import (
 	"github.com/vmware/govmomi/vim25/mo"
 )
 
-
-
 func (p *Poller) GetVMs() (vmList []common.Vm, err error) {
 
 	// log time on debug

poller/poller.go

@@ -68,4 +68,4 @@ func logPollingResult(err error) {
 	} else {
 		log.Warningf("poll was not successful: %s", err)
 	}
-}
+}

server/handlers.go

@@ -92,7 +92,6 @@ func handlerPoller(w http.ResponseWriter, req *http.Request) {
 		return
 	}
 
-
 	// insert to backend
 	err = backend.InsertPoller(poller)
 	if err != nil {