feat: optional run_name label for all metrics

Author: damiankaminski-form3

internal/run/main_test.go

@@ -13,6 +13,7 @@ import (
 var fakePrometheus FakePrometheus
 
 const fakePrometheusNamespace = "test-namespace"
+const fakePrometheusRunName = "test-run-name"
 
 func TestMain(m *testing.M) {
 
@@ -29,6 +30,10 @@ func TestMain(m *testing.M) {
 	if err != nil {
 		log.Fatal(err)
 	}
+	err = os.Setenv("PROMETHEUS_RUN_NAME_LABEL", fakePrometheusRunName)
+	if err != nil {
+		log.Fatal(err)
+	}
 
 	fakePrometheus.StartServer()
 

internal/run/run_cmd_test.go

@@ -585,7 +585,7 @@ func TestSetupMetricsAreRecorded(t *testing.T) {
 		there_is_a_metric_called("form3_loadtest_setup")
 }
 
-func TestNamespaceLabel(t *testing.T) {
+func TestGroupedLabels(t *testing.T) {
 	given, when, then := NewRunTestStage(t)
 
 	given.
@@ -596,7 +596,8 @@ func TestNamespaceLabel(t *testing.T) {
 
 	then.
 		metrics_are_pushed_to_prometheus().and().
-		all_exported_metrics_contain_label("namespace", fakePrometheusNamespace)
+		all_exported_metrics_contain_label("namespace", fakePrometheusNamespace).and().
+		all_exported_metrics_contain_label("run_name", fakePrometheusRunName)
 }
 
 func TestFailureCounts(t *testing.T) {

internal/run/test_runner.go

@@ -44,9 +44,14 @@ func NewRun(options options.RunOptions, t *api.Trigger) (*Run, error) {
 	if prometheusUrl != "" {
 		run.pusher = push.New(prometheusUrl, "f1-"+options.Scenario).Gatherer(prometheus.DefaultGatherer)
 
-		prometheusNamespace := os.Getenv("PROMETHEUS_NAMESPACE")
-		if prometheusNamespace != "" {
-			run.pusher = run.pusher.Grouping("namespace", prometheusNamespace)
+		namespaceLabel := os.Getenv("PROMETHEUS_NAMESPACE")
+		if namespaceLabel != "" {
+			run.pusher = run.pusher.Grouping("namespace", namespaceLabel)
+		}
+
+		runNameLabel := os.Getenv("PROMETHEUS_RUN_NAME_LABEL")
+		if runNameLabel != "" {
+			run.pusher = run.pusher.Grouping("run_name", runNameLabel)
 		}
 	}
 	if run.Options.RegisterLogHookFunc == nil {