diff --git a/tests/server_test.go b/tests/server_test.go index 2954a3a103..bffe70fbd7 100644 --- a/tests/server_test.go +++ b/tests/server_test.go @@ -66,15 +66,16 @@ func TestServer_DatabaseCommands(t *testing.T) { test := tests.load(t, "database_commands") for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -90,20 +91,21 @@ func TestServer_Query_DropAndRecreateDatabase(t *testing.T) { } for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -122,20 +124,21 @@ func TestServer_Query_DropDatabaseIsolated(t *testing.T) { } for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -151,20 +154,21 @@ func TestServer_Query_DeleteSeries(t *testing.T) { } for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -180,40 +184,42 @@ func TestServer_Query_DropAndRecreateSeries(t *testing.T) { } for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } // Re-write data and test again. retest := tests.load(t, "drop_and_recreate_series_retest") for i, query := range retest.queries { - if i == 0 { - if err := retest.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := retest.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -229,20 +235,21 @@ func TestServer_Query_DropSeriesFromRegex(t *testing.T) { } for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -266,15 +273,16 @@ func TestServer_RetentionPolicyCommands(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -287,15 +295,16 @@ func TestServer_DatabaseRetentionPolicyAutoCreate(t *testing.T) { test := tests.load(t, "retention_policy_auto_create") for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -325,15 +334,16 @@ func TestServer_ShowDatabases_NoAuth(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(fmt.Sprintf("command: %s - err: %s", query.command, query.Error(err))) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(fmt.Sprintf("command: %s - err: %s", query.command, query.Error(err))) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -400,11 +410,13 @@ func TestServer_ShowDatabases_WithAuth(t *testing.T) { } for _, query := range test.queries { - if err := query.Execute(s); err != nil { - t.Error(fmt.Sprintf("command: %s - err: %s", query.command, query.Error(err))) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if err := query.Execute(s); err != nil { + t.Error(fmt.Sprintf("command: %s - err: %s", query.command, query.Error(err))) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -490,15 +502,16 @@ func TestServer_UserCommands(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(fmt.Sprintf("command: %s - err: %s", query.command, query.Error(err))) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(fmt.Sprintf("command: %s - err: %s", query.command, query.Error(err))) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -728,15 +741,16 @@ func TestServer_Query_DefaultDBAndRP(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -774,15 +788,16 @@ func TestServer_Query_Multiple_Measurements(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -825,15 +840,16 @@ func TestServer_Query_IdenticalTagValues(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -863,15 +879,16 @@ func TestServer_Query_NoShards(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -906,15 +923,16 @@ func TestServer_Query_NonExistent(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -998,15 +1016,16 @@ func TestServer_Query_Math(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -1073,15 +1092,16 @@ func TestServer_Query_Count(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -1118,15 +1138,16 @@ func TestServer_Query_MaxSelectSeriesN(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -1171,15 +1192,16 @@ func TestServer_Query_Now(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -1240,15 +1262,16 @@ func TestServer_Query_EpochPrecision(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -1417,15 +1440,16 @@ func TestServer_Query_Tags(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -1492,15 +1516,16 @@ func TestServer_Query_Alias(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -1565,15 +1590,16 @@ func TestServer_Query_Common(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -1604,20 +1630,21 @@ func TestServer_Query_SelectTwoPoints(t *testing.T) { ) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -1641,20 +1668,21 @@ func TestServer_Query_SelectTwoNegativePoints(t *testing.T) { }) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -1686,20 +1714,21 @@ func TestServer_Query_SelectRelativeTime(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -1728,20 +1757,21 @@ func TestServer_Query_SelectRawDerivative(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -1774,20 +1804,21 @@ cpu value=20 1278010024000000000 }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -1925,20 +1956,21 @@ cpu0,host=server02 ticks=101,total=100 1278010023000000000 }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -2159,20 +2191,21 @@ cpu value=20 1278010021000000000 }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -2245,20 +2278,21 @@ cpu value=25 1278010023000000000 }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -2379,20 +2413,21 @@ cpu value=20 1278010021000000000 }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -2467,20 +2502,21 @@ cpu value=35 1278010025000000000 }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -2603,20 +2639,21 @@ cpu value=35 1278010025000000000 }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -2689,20 +2726,21 @@ cpu value=25 1278010023000000000 }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -2823,20 +2861,21 @@ cpu value=20 1278010021000000000 }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -2865,20 +2904,21 @@ events signup=t 3838400000 }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -2907,20 +2947,21 @@ test,t=b y=3i 3000000000 }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -2949,20 +2990,21 @@ func TestServer_Query_MathWithFill(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -3011,20 +3053,21 @@ func TestServer_Query_MergeMany(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -3068,20 +3111,21 @@ func TestServer_Query_SLimitAndSOffset(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -3143,20 +3187,21 @@ func TestServer_Query_Regex(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -3183,20 +3228,21 @@ func TestServer_Query_Aggregates_Int(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -3223,20 +3269,21 @@ func TestServer_Query_Aggregates_IntMax(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -3369,20 +3416,21 @@ func TestServer_Query_Aggregates_IntMany(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -3463,20 +3511,21 @@ func TestServer_Query_Aggregates_IntMany_GroupBy(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -3509,20 +3558,21 @@ func TestServer_Query_Aggregates_IntMany_OrderByDesc(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -3576,20 +3626,21 @@ func TestServer_Query_Aggregates_IntOverlap(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -3615,20 +3666,21 @@ func TestServer_Query_Aggregates_FloatSingle(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -3755,20 +3807,21 @@ func TestServer_Query_Aggregates_FloatMany(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -3821,20 +3874,21 @@ func TestServer_Query_Aggregates_FloatOverlap(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -3880,20 +3934,21 @@ func TestServer_Query_Aggregates_GroupByOffset(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -3933,20 +3988,21 @@ func TestServer_Query_Aggregates_Load(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -3973,20 +4029,21 @@ func TestServer_Query_Aggregates_CPU(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -4050,20 +4107,21 @@ func TestServer_Query_Aggregates_String(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -4115,21 +4173,22 @@ func TestServer_Query_Aggregates_Math(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } + } + if query.skip { + t.Skipf("SKIP:: %s", query.name) } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -4444,21 +4503,22 @@ func TestServer_Query_AggregateSelectors(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } + } + if query.skip { + t.Skipf("SKIP:: %s", query.name) } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -4498,21 +4558,22 @@ func TestServer_Query_ExactTimeRange(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } + } + if query.skip { + t.Skipf("SKIP:: %s", query.name) } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -4576,21 +4637,22 @@ func TestServer_Query_Selectors(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } + } + if query.skip { + t.Skipf("SKIP:: %s", query.name) } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -4829,21 +4891,22 @@ func TestServer_Query_TopBottomInt(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } + } + if query.skip { + t.Skipf("SKIP: %s", query.name) } - } - if query.skip { - t.Logf("SKIP: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -4896,21 +4959,22 @@ func TestServer_Query_TopBottomWriteTags(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } + } + if query.skip { + t.Skipf("SKIP: %s", query.name) } - } - if query.skip { - t.Logf("SKIP: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -4959,22 +5023,23 @@ func TestServer_Query_Aggregates_IdenticalTime(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - for n := 0; n <= query.repeat; n++ { - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) + if query.skip { + t.Skipf("SKIP:: %s", query.name) } - } + for n := 0; n <= query.repeat; n++ { + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + } + }) } } @@ -5042,20 +5107,21 @@ func TestServer_Query_GroupByTimeCutoffs(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -5117,20 +5183,21 @@ func TestServer_Query_MapType(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -5349,20 +5416,21 @@ func TestServer_Query_SubqueryWithGroupBy(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -5397,20 +5465,21 @@ func TestServer_Query_PercentileDerivative(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -5441,20 +5510,21 @@ func TestServer_Query_UnderscoreMeasurement(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -5560,15 +5630,16 @@ func TestServer_Write_Precision(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -5669,21 +5740,22 @@ func TestServer_Query_Wildcards(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } + } + if query.skip { + t.Skipf("SKIP:: %s", query.name) } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -5747,20 +5819,21 @@ func TestServer_Query_WildcardExpansion(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -5818,20 +5891,21 @@ func TestServer_Query_AcrossShardsAndFields(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -5885,20 +5959,21 @@ func TestServer_Query_OrderedAcrossShards(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -6103,21 +6178,22 @@ func TestServer_Query_Where_Fields(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } + } + if query.skip { + t.Skipf("SKIP:: %s", query.name) } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -6189,20 +6265,21 @@ func TestServer_Query_Where_With_Tags(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -6289,20 +6366,21 @@ func TestServer_Query_With_EmptyTags(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -6403,20 +6481,21 @@ func TestServer_Query_LimitAndOffset(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -6499,20 +6578,21 @@ func TestServer_Query_Fill(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -6594,20 +6674,21 @@ func TestServer_Query_TimeZone(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -6645,20 +6726,21 @@ func TestServer_Query_Chunk(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -6768,20 +6850,21 @@ func TestServer_Query_DropAndRecreateMeasurement(t *testing.T) { // Test that re-inserting the measurement works fine. for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } test = NewTest("db0", "rp0") @@ -6805,20 +6888,21 @@ func TestServer_Query_DropAndRecreateMeasurement(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -6874,20 +6958,21 @@ func TestServer_Query_ShowQueries_Future(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -6973,20 +7058,21 @@ func TestServer_Query_ShowSeries(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -7066,20 +7152,21 @@ func TestServer_Query_ShowSeriesCardinality(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -7107,20 +7194,21 @@ func TestServer_Query_ShowStats(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -7281,20 +7369,21 @@ func TestServer_Query_ShowMeasurementCardinality(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -7428,20 +7517,21 @@ func TestServer_Query_ShowTagKeys(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -7551,20 +7641,21 @@ func TestServer_Query_ShowTagKeyCardinality(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -7614,20 +7705,21 @@ func TestServer_Query_ShowFieldKeys(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -7677,20 +7769,21 @@ func TestServer_Query_ShowFieldKeyCardinality(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -7705,20 +7798,21 @@ func TestServer_ContinuousQuery(t *testing.T) { runTest := func(test *Test, t *testing.T) { for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -7834,20 +7928,21 @@ func TestServer_ContinuousQuery_Deadlock(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } // Deadlock detector. If the deadlock is fixed, this test should complete all the writes in ~2.5s seconds (with artifical delays @@ -7908,20 +8003,21 @@ func TestServer_Query_EvilIdentifiers(t *testing.T) { }...) for i, query := range test.queries { - if i == 0 { - if err := test.init(s); err != nil { - t.Fatalf("test init failed: %s", err) + t.Run(query.name, func(t *testing.T) { + if i == 0 { + if err := test.init(s); err != nil { + t.Fatalf("test init failed: %s", err) + } } - } - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -8147,15 +8243,16 @@ func TestServer_Query_IntoTarget(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -8204,15 +8301,16 @@ func TestServer_Query_IntoTarget_Sparse(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -8256,15 +8354,16 @@ func TestServer_Query_DuplicateMeasurements(t *testing.T) { }...) for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -8305,15 +8404,16 @@ func TestServer_Query_LargeTimestamp(t *testing.T) { defer s2.Close() for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -8352,15 +8452,16 @@ func TestServer_Query_DotProduct(t *testing.T) { }...) for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -8491,15 +8592,16 @@ func TestServer_WhereTimeInclusive(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -8546,15 +8648,16 @@ func TestServer_Query_ImplicitEndTime(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -8590,15 +8693,16 @@ func TestServer_Query_Sample_Wildcard(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -8648,15 +8752,16 @@ func TestServer_Query_Sample_LimitOffset(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } } @@ -8699,14 +8804,15 @@ func TestServer_NestedAggregateWithMathPanics(t *testing.T) { } for _, query := range test.queries { - if query.skip { - t.Logf("SKIP:: %s", query.name) - continue - } - if err := query.Execute(s); err != nil { - t.Error(query.Error(err)) - } else if !query.success() { - t.Error(query.failureMessage()) - } + t.Run(query.name, func(t *testing.T) { + if query.skip { + t.Skipf("SKIP:: %s", query.name) + } + if err := query.Execute(s); err != nil { + t.Error(query.Error(err)) + } else if !query.success() { + t.Error(query.failureMessage()) + } + }) } }