|
|
|
|
@ -1011,7 +1011,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "p75") |
|
|
|
|
assert.Equal(t, frame.Name, "p75") |
|
|
|
|
|
|
|
|
|
frame = dataframes[1] |
|
|
|
|
require.Len(t, frame.Fields, 2) |
|
|
|
|
@ -1019,7 +1019,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "p90") |
|
|
|
|
assert.Equal(t, frame.Name, "p90") |
|
|
|
|
}) |
|
|
|
|
}) |
|
|
|
|
|
|
|
|
|
@ -1478,7 +1478,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
assert.Len(t, frame.Fields, 2) |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "Top Metrics @value") |
|
|
|
|
assert.Equal(t, frame.Name, "Top Metrics @value") |
|
|
|
|
v, _ := frame.FloatAt(0, 0) |
|
|
|
|
assert.Equal(t, 1609459200000., v) |
|
|
|
|
v, _ = frame.FloatAt(1, 0) |
|
|
|
|
@ -1495,7 +1495,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
assert.Len(t, frame.Fields, 2) |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "Top Metrics @anotherValue") |
|
|
|
|
assert.Equal(t, frame.Name, "Top Metrics @anotherValue") |
|
|
|
|
v, _ = frame.FloatAt(0, 0) |
|
|
|
|
assert.Equal(t, 1609459200000., v) |
|
|
|
|
v, _ = frame.FloatAt(1, 0) |
|
|
|
|
@ -1764,7 +1764,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "server1") |
|
|
|
|
assert.Equal(t, frame.Name, "server1") |
|
|
|
|
|
|
|
|
|
frame = dataframes[1] |
|
|
|
|
require.Len(t, frame.Fields, 2) |
|
|
|
|
@ -1772,7 +1772,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "server2") |
|
|
|
|
assert.Equal(t, frame.Name, "server2") |
|
|
|
|
}) |
|
|
|
|
|
|
|
|
|
t.Run("Single group by query two metrics", func(t *testing.T) { |
|
|
|
|
@ -1833,7 +1833,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "server1 Count") |
|
|
|
|
assert.Equal(t, frame.Name, "server1 Count") |
|
|
|
|
|
|
|
|
|
frame = dataframes[1] |
|
|
|
|
require.Len(t, frame.Fields, 2) |
|
|
|
|
@ -1841,7 +1841,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "server1 Average @value") |
|
|
|
|
assert.Equal(t, frame.Name, "server1 Average @value") |
|
|
|
|
|
|
|
|
|
frame = dataframes[2] |
|
|
|
|
require.Len(t, frame.Fields, 2) |
|
|
|
|
@ -1849,7 +1849,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "server2 Count") |
|
|
|
|
assert.Equal(t, frame.Name, "server2 Count") |
|
|
|
|
|
|
|
|
|
frame = dataframes[3] |
|
|
|
|
require.Len(t, frame.Fields, 2) |
|
|
|
|
@ -1857,7 +1857,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "server2 Average @value") |
|
|
|
|
assert.Equal(t, frame.Name, "server2 Average @value") |
|
|
|
|
}) |
|
|
|
|
|
|
|
|
|
t.Run("Simple group by 2 metrics 4 frames", func(t *testing.T) { |
|
|
|
|
@ -1985,7 +1985,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "server1 Count and {{not_exist}} server1") |
|
|
|
|
assert.Equal(t, frame.Name, "server1 Count and {{not_exist}} server1") |
|
|
|
|
|
|
|
|
|
frame = dataframes[1] |
|
|
|
|
require.Len(t, frame.Fields, 2) |
|
|
|
|
@ -1993,7 +1993,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "server2 Count and {{not_exist}} server2") |
|
|
|
|
assert.Equal(t, frame.Name, "server2 Count and {{not_exist}} server2") |
|
|
|
|
|
|
|
|
|
frame = dataframes[2] |
|
|
|
|
require.Len(t, frame.Fields, 2) |
|
|
|
|
@ -2001,7 +2001,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "0 Count and {{not_exist}} 0") |
|
|
|
|
assert.Equal(t, frame.Name, "0 Count and {{not_exist}} 0") |
|
|
|
|
}) |
|
|
|
|
}) |
|
|
|
|
|
|
|
|
|
@ -2158,7 +2158,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 1) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 1) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "server1 Max") |
|
|
|
|
assert.Equal(t, frame.Name, "server1 Max") |
|
|
|
|
|
|
|
|
|
frame = dataframes[1] |
|
|
|
|
require.Len(t, frame.Fields, 2) |
|
|
|
|
@ -2166,7 +2166,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 1) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 1) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "server1 Std Dev Lower") |
|
|
|
|
assert.Equal(t, frame.Name, "server1 Std Dev Lower") |
|
|
|
|
|
|
|
|
|
frame = dataframes[2] |
|
|
|
|
require.Len(t, frame.Fields, 2) |
|
|
|
|
@ -2174,7 +2174,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 1) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 1) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "server1 Std Dev Upper") |
|
|
|
|
assert.Equal(t, frame.Name, "server1 Std Dev Upper") |
|
|
|
|
|
|
|
|
|
frame = dataframes[3] |
|
|
|
|
require.Len(t, frame.Fields, 2) |
|
|
|
|
@ -2182,7 +2182,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 1) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 1) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "server2 Max") |
|
|
|
|
assert.Equal(t, frame.Name, "server2 Max") |
|
|
|
|
|
|
|
|
|
frame = dataframes[4] |
|
|
|
|
require.Len(t, frame.Fields, 2) |
|
|
|
|
@ -2190,7 +2190,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 1) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 1) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "server2 Std Dev Lower") |
|
|
|
|
assert.Equal(t, frame.Name, "server2 Std Dev Lower") |
|
|
|
|
|
|
|
|
|
frame = dataframes[5] |
|
|
|
|
require.Len(t, frame.Fields, 2) |
|
|
|
|
@ -2198,7 +2198,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 1) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 1) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "server2 Std Dev Upper") |
|
|
|
|
assert.Equal(t, frame.Name, "server2 Std Dev Upper") |
|
|
|
|
}) |
|
|
|
|
}) |
|
|
|
|
|
|
|
|
|
@ -2290,7 +2290,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "Count") |
|
|
|
|
assert.Equal(t, frame.Name, "Count") |
|
|
|
|
}) |
|
|
|
|
|
|
|
|
|
t.Run("Simple query count & avg aggregation", func(t *testing.T) { |
|
|
|
|
@ -2339,7 +2339,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "Count") |
|
|
|
|
assert.Equal(t, frame.Name, "Count") |
|
|
|
|
|
|
|
|
|
frame = dataframes[1] |
|
|
|
|
require.Len(t, frame.Fields, 2) |
|
|
|
|
@ -2348,7 +2348,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "Average value") |
|
|
|
|
assert.Equal(t, frame.Name, "Average value") |
|
|
|
|
}) |
|
|
|
|
}) |
|
|
|
|
|
|
|
|
|
@ -2522,7 +2522,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "@metric:cpu") |
|
|
|
|
assert.Equal(t, frame.Name, "@metric:cpu") |
|
|
|
|
|
|
|
|
|
frame = dataframes[1] |
|
|
|
|
require.Len(t, frame.Fields, 2) |
|
|
|
|
@ -2530,7 +2530,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "@metric:logins.count") |
|
|
|
|
assert.Equal(t, frame.Name, "@metric:logins.count") |
|
|
|
|
}) |
|
|
|
|
}) |
|
|
|
|
|
|
|
|
|
@ -2737,7 +2737,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 1) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 1) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "Average") |
|
|
|
|
assert.Equal(t, frame.Name, "Average") |
|
|
|
|
|
|
|
|
|
frame = dataframes[1] |
|
|
|
|
require.Len(t, frame.Fields, 2) |
|
|
|
|
@ -2745,7 +2745,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 1) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 1) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "Count") |
|
|
|
|
assert.Equal(t, frame.Name, "Count") |
|
|
|
|
}) |
|
|
|
|
|
|
|
|
|
t.Run("With drop first and last aggregation (string)", func(t *testing.T) { |
|
|
|
|
@ -2805,7 +2805,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 1) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 1) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "Average") |
|
|
|
|
assert.Equal(t, frame.Name, "Average") |
|
|
|
|
|
|
|
|
|
frame = dataframes[1] |
|
|
|
|
require.Len(t, frame.Fields, 2) |
|
|
|
|
@ -2813,7 +2813,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 1) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 1) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "Count") |
|
|
|
|
assert.Equal(t, frame.Name, "Count") |
|
|
|
|
}) |
|
|
|
|
}) |
|
|
|
|
|
|
|
|
|
@ -2923,7 +2923,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "Sum @value") |
|
|
|
|
assert.Equal(t, frame.Name, "Sum @value") |
|
|
|
|
|
|
|
|
|
frame = dataframes[1] |
|
|
|
|
require.Len(t, frame.Fields, 2) |
|
|
|
|
@ -2931,7 +2931,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "Max @value") |
|
|
|
|
assert.Equal(t, frame.Name, "Max @value") |
|
|
|
|
|
|
|
|
|
frame = dataframes[2] |
|
|
|
|
require.Len(t, frame.Fields, 2) |
|
|
|
|
@ -2939,7 +2939,7 @@ func TestProcessBuckets(t *testing.T) { |
|
|
|
|
require.Equal(t, frame.Fields[0].Len(), 2) |
|
|
|
|
require.Equal(t, frame.Fields[1].Name, data.TimeSeriesValueFieldName) |
|
|
|
|
require.Equal(t, frame.Fields[1].Len(), 2) |
|
|
|
|
assert.Equal(t, frame.Fields[1].Config.DisplayNameFromDS, "Sum @value * Max @value") |
|
|
|
|
assert.Equal(t, frame.Name, "Sum @value * Max @value") |
|
|
|
|
}) |
|
|
|
|
|
|
|
|
|
t.Run("Two bucket_script", func(t *testing.T) { |
|
|
|
|
@ -3672,16 +3672,5 @@ func requireFloatAt(t *testing.T, expected float64, field *data.Field, index int |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
func requireTimeSeriesName(t *testing.T, expected string, frame *data.Frame) { |
|
|
|
|
getField := func() *data.Field { |
|
|
|
|
for _, field := range frame.Fields { |
|
|
|
|
if field.Type() != data.FieldTypeTime { |
|
|
|
|
return field |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
return nil |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
field := getField() |
|
|
|
|
require.NotNil(t, expected, field.Config) |
|
|
|
|
require.Equal(t, expected, field.Config.DisplayNameFromDS) |
|
|
|
|
require.Equal(t, expected, frame.Name) |
|
|
|
|
} |
|
|
|
|
|