go fmt

Author: mblaschke

logger.go

@@ -1,13 +1,13 @@
 package main
 
 import (
+	"fmt"
 	"log"
 	"os"
-	"fmt"
 )
 
 const (
-	LoggerLogPrefix = ""
+	LoggerLogPrefix      = ""
 	LoggerLogPrefixError = "[ERROR] "
 )
 

main.go

@@ -1,12 +1,12 @@
 package main
 
 import (
-	"os"
 	"fmt"
-	"time"
-	"strings"
-	"net/url"
 	"github.com/jessevdk/go-flags"
+	"net/url"
+	"os"
+	"strings"
+	"time"
 )
 
 const (
@@ -23,14 +23,14 @@ var (
 
 var opts struct {
 	// general options
-	ServerBind  string `       long:"bind"                env:"SERVER_BIND"   description:"Server address"                default:":8080"`
-	ScrapeTime  time.Duration `long:"scrape-time"         env:"SCRAPE_TIME"   description:"Scrape time in seconds"        default:"1m"`
-	Verbose []bool `           long:"verbose" short:"v"   env:"VERBOSE"       description:"Verbose mode"`
+	ServerBind string        `long:"bind"                env:"SERVER_BIND"   description:"Server address"                default:":8080"`
+	ScrapeTime time.Duration `long:"scrape-time"         env:"SCRAPE_TIME"   description:"Scrape time in seconds"        default:"1m"`
+	Verbose    []bool        `long:"verbose" short:"v"   env:"VERBOSE"       description:"Verbose mode"`
 
 	// Api options
-	ApiUrl      string `       long:"api-url"             env:"API_URL"       description:"Azure ScheduledEvents API URL" default:"http://169.254.169.254/metadata/scheduledevents?api-version=2017-11-01"`
-	ApiTimeout  time.Duration `long:"api-timeout"         env:"API_TIMEOUT"   description:"Azure API timeout (seconds)"   default:"30s"`
-	ApiErrorThreshold int `    long:"api-error-threshold" env:"API_ERROR_THRESHOLD"   description:"Azure API error threshold (after which app will panic)"   default:"0"`
+	ApiUrl            string        `long:"api-url"             env:"API_URL"       description:"Azure ScheduledEvents API URL" default:"http://169.254.169.254/metadata/scheduledevents?api-version=2017-11-01"`
+	ApiTimeout        time.Duration `long:"api-timeout"         env:"API_TIMEOUT"   description:"Azure API timeout (seconds)"   default:"30s"`
+	ApiErrorThreshold int           `long:"api-error-threshold" env:"API_ERROR_THRESHOLD"   description:"Azure API error threshold (after which app will panic)"   default:"0"`
 }
 
 func main() {
@@ -86,11 +86,11 @@ func initArgparser() {
 	}
 
 	// validate --api-url scheme
-	switch (strings.ToLower(apiUrl.Scheme)) {
+	switch strings.ToLower(apiUrl.Scheme) {
 	case "http":
-		break;
+		break
 	case "https":
-		break;
+		break
 	default:
 		fmt.Println("ApiURL scheme not allowed (must be http or https)")
 		fmt.Println()

metrics.go

@@ -1,27 +1,27 @@
 package main
 
 import (
-	"log"
-	"fmt"
-	"time"
-	"net/http"
 	"encoding/json"
+	"fmt"
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/prometheus/client_golang/prometheus/promhttp"
+	"log"
+	"net/http"
+	"time"
 )
 
 type AzureScheduledEventResponse struct {
-	DocumentIncarnation int `json:"DocumentIncarnation"`
-	Events []AzureScheduledEvent `json:"Events"`
+	DocumentIncarnation int                   `json:"DocumentIncarnation"`
+	Events              []AzureScheduledEvent `json:"Events"`
 }
 
 type AzureScheduledEvent struct {
-	EventId string `json:"EventId"`
-	EventType string `json:"EventType"`
-	ResourceType string `json:"ResourceType"`
-	Resources []string `json:"Resources"`
-	EventStatus string `json:"EventStatus"`
-	NotBefore string `json:"NotBefore"`
+	EventId      string   `json:"EventId"`
+	EventType    string   `json:"EventType"`
+	ResourceType string   `json:"ResourceType"`
+	Resources    []string `json:"Resources"`
+	EventStatus  string   `json:"EventStatus"`
+	NotBefore    string   `json:"NotBefore"`
 }
 
 var (
@@ -69,7 +69,6 @@ var (
 	apiErrorCount = 0
 )
 
-
 func setupMetricsCollection() {
 	prometheus.MustRegister(scheduledEvent)
 	prometheus.MustRegister(scheduledEventDocumentIncarnation)
@@ -132,30 +131,30 @@ func probeCollect() {
 			for _, resource := range event.Resources {
 				scheduledEvent.With(
 					prometheus.Labels{
-						"eventID": event.EventId,
-						"eventType": event.EventType,
+						"eventID":      event.EventId,
+						"eventType":    event.EventType,
 						"resourceType": event.ResourceType,
-						"resource": resource,
-						"eventStatus": event.EventStatus,
-						"notBefore": event.NotBefore,
+						"resource":     resource,
+						"eventStatus":  event.EventStatus,
+						"notBefore":    event.NotBefore,
 					}).Set(eventValue)
 			}
 		} else {
 			scheduledEvent.With(
 				prometheus.Labels{
-					"eventID": event.EventId,
-					"eventType": event.EventType,
+					"eventID":      event.EventId,
+					"eventType":    event.EventType,
 					"resourceType": event.ResourceType,
-					"resource": "",
-					"eventStatus": event.EventStatus,
-					"notBefore": event.NotBefore,
+					"resource":     "",
+					"eventStatus":  event.EventStatus,
+					"notBefore":    event.NotBefore,
 				}).Set(eventValue)
 		}
 	}
 
 	scheduledEventDocumentIncarnation.With(prometheus.Labels{}).Set(float64(scheduledEvents.DocumentIncarnation))
 
-	Logger.Verbose("Fetched %v Azure ScheduledEvents",len(scheduledEvents.Events))
+	Logger.Verbose("Fetched %v Azure ScheduledEvents", len(scheduledEvents.Events))
 }
 
 func fetchApiUrl() (*AzureScheduledEventResponse, error) {