Merge pull request #2 from cloud-bulldozer/quay

Modify quay URL

README.md

@@ -18,7 +18,7 @@ Kube-burner is a tool aimed to stress a kubernetes cluster. An overview of its b
 In case you want to start tinkering with `kube-burner` now:
 
 - You can find the binaries in the [releases section of this repository](https://github.com/cloud-bulldozer/kube-burner/releases).
-- There's also a container image available at [quay](https://quay.io/repository/rsevilla/kube-burner?tab=tags).
+- There's also a container image available at [quay](https://quay.io/repository/cloud-bulldozer/kube-burner?tab=tags).
 - A valid example of a configuration file can be found at [./examples/cfg.yml](./examples/cfg.yml)
 
 

cmd/kube-burner.go

@@ -187,10 +187,10 @@ func init() {
 
 func steps(uuid string, p *prometheus.Prometheus) {
 	var indexer *indexers.Indexer
-	executorList := burner.NewExecutorList(uuid)
 	if config.ConfigSpec.GlobalConfig.IndexerConfig.Enabled {
 		indexer = indexers.NewIndexer(config.ConfigSpec.GlobalConfig.IndexerConfig)
 	}
+	executorList := burner.NewExecutorList(uuid)
 	for _, job := range executorList {
 		log.Infof("Triggering job: %s with UUID %s", job.Config.Name, uuid)
 		job.Cleanup()

pkg/indexers/elastic.go

@@ -53,8 +53,11 @@ func (esIndexer *Elastic) new(esConfig config.IndexerConfig) {
 		log.Errorf("Error creating the ES client: %s", err)
 	}
 	r, err := ESClient.Ping()
-	if err != nil || r.StatusCode != 200 {
-		log.Fatalf("ES connection error: %s %d", err, r.StatusCode)
+	if err != nil {
+		log.Fatalf("ES connection error: %s", err)
+	}
+	if r.StatusCode != 200 {
+		log.Fatalf("Unexpected ES status code: %d", r.StatusCode)
 	}
 	esIndexer.client = ESClient
 }

pkg/prometheus/prometheus.go

@@ -25,12 +25,12 @@ import (
 	"strings"
 	"time"
 
-	api "github.com/prometheus/client_golang/api"
-	apiv1 "github.com/prometheus/client_golang/api/prometheus/v1"
-	"github.com/prometheus/common/model"
 	"github.com/cloud-bulldozer/kube-burner/log"
 	"github.com/cloud-bulldozer/kube-burner/pkg/config"
 	"github.com/cloud-bulldozer/kube-burner/pkg/indexers"
+	api "github.com/prometheus/client_golang/api"
+	apiv1 "github.com/prometheus/client_golang/api/prometheus/v1"
+	"github.com/prometheus/common/model"
 	"gopkg.in/yaml.v3"
 )
 
@@ -90,7 +90,7 @@ func NewPrometheusClient(url, token, username, password, metricsProfile, uuid st
 		step: prometheusStep,
 		uuid: uuid,
 	}
-	log.Info("Initializing prometheus client")
+	log.Info("👽 Initializing prometheus client")
 	cfg := api.Config{
 		Address: url,
 		RoundTripper: authTransport{