Commit d2f31a71 by Marcus Efraimsson

remove unnecessary conversions

parent 723a894f
...@@ -50,7 +50,7 @@ func TestAlertRuleExtraction(t *testing.T) { ...@@ -50,7 +50,7 @@ func TestAlertRuleExtraction(t *testing.T) {
So(err, ShouldBeNil) So(err, ShouldBeNil)
Convey("Extractor should not modify the original json", func() { Convey("Extractor should not modify the original json", func() {
dashJson, err := simplejson.NewJson([]byte(json)) dashJson, err := simplejson.NewJson(json)
So(err, ShouldBeNil) So(err, ShouldBeNil)
dash := m.NewDashboardFromJson(dashJson) dash := m.NewDashboardFromJson(dashJson)
...@@ -79,7 +79,7 @@ func TestAlertRuleExtraction(t *testing.T) { ...@@ -79,7 +79,7 @@ func TestAlertRuleExtraction(t *testing.T) {
Convey("Parsing and validating dashboard containing graphite alerts", func() { Convey("Parsing and validating dashboard containing graphite alerts", func() {
dashJson, err := simplejson.NewJson([]byte(json)) dashJson, err := simplejson.NewJson(json)
So(err, ShouldBeNil) So(err, ShouldBeNil)
dash := m.NewDashboardFromJson(dashJson) dash := m.NewDashboardFromJson(dashJson)
...@@ -143,7 +143,7 @@ func TestAlertRuleExtraction(t *testing.T) { ...@@ -143,7 +143,7 @@ func TestAlertRuleExtraction(t *testing.T) {
panelWithoutId, err := ioutil.ReadFile("./test-data/panels-missing-id.json") panelWithoutId, err := ioutil.ReadFile("./test-data/panels-missing-id.json")
So(err, ShouldBeNil) So(err, ShouldBeNil)
dashJson, err := simplejson.NewJson([]byte(panelWithoutId)) dashJson, err := simplejson.NewJson(panelWithoutId)
So(err, ShouldBeNil) So(err, ShouldBeNil)
dash := m.NewDashboardFromJson(dashJson) dash := m.NewDashboardFromJson(dashJson)
extractor := NewDashAlertExtractor(dash, 1) extractor := NewDashAlertExtractor(dash, 1)
...@@ -159,7 +159,7 @@ func TestAlertRuleExtraction(t *testing.T) { ...@@ -159,7 +159,7 @@ func TestAlertRuleExtraction(t *testing.T) {
panelWithIdZero, err := ioutil.ReadFile("./test-data/panel-with-id-0.json") panelWithIdZero, err := ioutil.ReadFile("./test-data/panel-with-id-0.json")
So(err, ShouldBeNil) So(err, ShouldBeNil)
dashJson, err := simplejson.NewJson([]byte(panelWithIdZero)) dashJson, err := simplejson.NewJson(panelWithIdZero)
So(err, ShouldBeNil) So(err, ShouldBeNil)
dash := m.NewDashboardFromJson(dashJson) dash := m.NewDashboardFromJson(dashJson)
extractor := NewDashAlertExtractor(dash, 1) extractor := NewDashAlertExtractor(dash, 1)
......
...@@ -32,7 +32,7 @@ func TestSearchRequest(t *testing.T) { ...@@ -32,7 +32,7 @@ func TestSearchRequest(t *testing.T) {
Convey("When marshal to JSON should generate correct json", func() { Convey("When marshal to JSON should generate correct json", func() {
body, err := json.Marshal(sr) body, err := json.Marshal(sr)
So(err, ShouldBeNil) So(err, ShouldBeNil)
json, err := simplejson.NewJson([]byte(body)) json, err := simplejson.NewJson(body)
So(err, ShouldBeNil) So(err, ShouldBeNil)
So(json.Get("size").MustInt(500), ShouldEqual, 0) So(json.Get("size").MustInt(500), ShouldEqual, 0)
So(json.Get("sort").Interface(), ShouldBeNil) So(json.Get("sort").Interface(), ShouldBeNil)
...@@ -81,7 +81,7 @@ func TestSearchRequest(t *testing.T) { ...@@ -81,7 +81,7 @@ func TestSearchRequest(t *testing.T) {
Convey("When marshal to JSON should generate correct json", func() { Convey("When marshal to JSON should generate correct json", func() {
body, err := json.Marshal(sr) body, err := json.Marshal(sr)
So(err, ShouldBeNil) So(err, ShouldBeNil)
json, err := simplejson.NewJson([]byte(body)) json, err := simplejson.NewJson(body)
So(err, ShouldBeNil) So(err, ShouldBeNil)
So(json.Get("size").MustInt(0), ShouldEqual, 200) So(json.Get("size").MustInt(0), ShouldEqual, 200)
...@@ -124,7 +124,7 @@ func TestSearchRequest(t *testing.T) { ...@@ -124,7 +124,7 @@ func TestSearchRequest(t *testing.T) {
Convey("When marshal to JSON should generate correct json", func() { Convey("When marshal to JSON should generate correct json", func() {
body, err := json.Marshal(sr) body, err := json.Marshal(sr)
So(err, ShouldBeNil) So(err, ShouldBeNil)
json, err := simplejson.NewJson([]byte(body)) json, err := simplejson.NewJson(body)
So(err, ShouldBeNil) So(err, ShouldBeNil)
scriptFields, err := json.Get("script_fields").Map() scriptFields, err := json.Get("script_fields").Map()
...@@ -163,7 +163,7 @@ func TestSearchRequest(t *testing.T) { ...@@ -163,7 +163,7 @@ func TestSearchRequest(t *testing.T) {
Convey("When marshal to JSON should generate correct json", func() { Convey("When marshal to JSON should generate correct json", func() {
body, err := json.Marshal(sr) body, err := json.Marshal(sr)
So(err, ShouldBeNil) So(err, ShouldBeNil)
json, err := simplejson.NewJson([]byte(body)) json, err := simplejson.NewJson(body)
So(err, ShouldBeNil) So(err, ShouldBeNil)
So(json.Get("aggs").MustMap(), ShouldHaveLength, 2) So(json.Get("aggs").MustMap(), ShouldHaveLength, 2)
...@@ -200,7 +200,7 @@ func TestSearchRequest(t *testing.T) { ...@@ -200,7 +200,7 @@ func TestSearchRequest(t *testing.T) {
Convey("When marshal to JSON should generate correct json", func() { Convey("When marshal to JSON should generate correct json", func() {
body, err := json.Marshal(sr) body, err := json.Marshal(sr)
So(err, ShouldBeNil) So(err, ShouldBeNil)
json, err := simplejson.NewJson([]byte(body)) json, err := simplejson.NewJson(body)
So(err, ShouldBeNil) So(err, ShouldBeNil)
So(json.Get("aggs").MustMap(), ShouldHaveLength, 1) So(json.Get("aggs").MustMap(), ShouldHaveLength, 1)
...@@ -251,7 +251,7 @@ func TestSearchRequest(t *testing.T) { ...@@ -251,7 +251,7 @@ func TestSearchRequest(t *testing.T) {
Convey("When marshal to JSON should generate correct json", func() { Convey("When marshal to JSON should generate correct json", func() {
body, err := json.Marshal(sr) body, err := json.Marshal(sr)
So(err, ShouldBeNil) So(err, ShouldBeNil)
json, err := simplejson.NewJson([]byte(body)) json, err := simplejson.NewJson(body)
So(err, ShouldBeNil) So(err, ShouldBeNil)
topAggOne := json.GetPath("aggs", "1") topAggOne := json.GetPath("aggs", "1")
...@@ -300,7 +300,7 @@ func TestSearchRequest(t *testing.T) { ...@@ -300,7 +300,7 @@ func TestSearchRequest(t *testing.T) {
Convey("When marshal to JSON should generate correct json", func() { Convey("When marshal to JSON should generate correct json", func() {
body, err := json.Marshal(sr) body, err := json.Marshal(sr)
So(err, ShouldBeNil) So(err, ShouldBeNil)
json, err := simplejson.NewJson([]byte(body)) json, err := simplejson.NewJson(body)
So(err, ShouldBeNil) So(err, ShouldBeNil)
topAgg := json.GetPath("aggs", "1") topAgg := json.GetPath("aggs", "1")
...@@ -364,7 +364,7 @@ func TestSearchRequest(t *testing.T) { ...@@ -364,7 +364,7 @@ func TestSearchRequest(t *testing.T) {
Convey("When marshal to JSON should generate correct json", func() { Convey("When marshal to JSON should generate correct json", func() {
body, err := json.Marshal(sr) body, err := json.Marshal(sr)
So(err, ShouldBeNil) So(err, ShouldBeNil)
json, err := simplejson.NewJson([]byte(body)) json, err := simplejson.NewJson(body)
So(err, ShouldBeNil) So(err, ShouldBeNil)
termsAgg := json.GetPath("aggs", "1") termsAgg := json.GetPath("aggs", "1")
...@@ -419,7 +419,7 @@ func TestSearchRequest(t *testing.T) { ...@@ -419,7 +419,7 @@ func TestSearchRequest(t *testing.T) {
Convey("When marshal to JSON should generate correct json", func() { Convey("When marshal to JSON should generate correct json", func() {
body, err := json.Marshal(sr) body, err := json.Marshal(sr)
So(err, ShouldBeNil) So(err, ShouldBeNil)
json, err := simplejson.NewJson([]byte(body)) json, err := simplejson.NewJson(body)
So(err, ShouldBeNil) So(err, ShouldBeNil)
scriptFields, err := json.Get("script_fields").Map() scriptFields, err := json.Get("script_fields").Map()
......
...@@ -531,7 +531,7 @@ func TestMSSQL(t *testing.T) { ...@@ -531,7 +531,7 @@ func TestMSSQL(t *testing.T) {
So(queryResult.Error, ShouldBeNil) So(queryResult.Error, ShouldBeNil)
So(len(queryResult.Series), ShouldEqual, 1) So(len(queryResult.Series), ShouldEqual, 1)
So(queryResult.Series[0].Points[0][1].Float64, ShouldEqual, float64(float64(float32(tInitial.Unix())))*1e3) So(queryResult.Series[0].Points[0][1].Float64, ShouldEqual, float64(float32(tInitial.Unix()))*1e3)
}) })
Convey("When doing a metric query using epoch (float32 nullable) as time column and value column (float32 nullable) should return metric with time in milliseconds", func() { Convey("When doing a metric query using epoch (float32 nullable) as time column and value column (float32 nullable) should return metric with time in milliseconds", func() {
...@@ -553,7 +553,7 @@ func TestMSSQL(t *testing.T) { ...@@ -553,7 +553,7 @@ func TestMSSQL(t *testing.T) {
So(queryResult.Error, ShouldBeNil) So(queryResult.Error, ShouldBeNil)
So(len(queryResult.Series), ShouldEqual, 1) So(len(queryResult.Series), ShouldEqual, 1)
So(queryResult.Series[0].Points[0][1].Float64, ShouldEqual, float64(float64(float32(tInitial.Unix())))*1e3) So(queryResult.Series[0].Points[0][1].Float64, ShouldEqual, float64(float32(tInitial.Unix()))*1e3)
}) })
Convey("When doing a metric query grouping by time and select metric column should return correct series", func() { Convey("When doing a metric query grouping by time and select metric column should return correct series", func() {
...@@ -930,7 +930,7 @@ func TestMSSQL(t *testing.T) { ...@@ -930,7 +930,7 @@ func TestMSSQL(t *testing.T) {
columns := queryResult.Tables[0].Rows[0] columns := queryResult.Tables[0].Rows[0]
//Should be in milliseconds //Should be in milliseconds
So(columns[0].(int64), ShouldEqual, int64(dt.Unix()*1000)) So(columns[0].(int64), ShouldEqual, dt.Unix()*1000)
}) })
Convey("When doing an annotation query with a time column in epoch second format (int) should return ms", func() { Convey("When doing an annotation query with a time column in epoch second format (int) should return ms", func() {
...@@ -960,7 +960,7 @@ func TestMSSQL(t *testing.T) { ...@@ -960,7 +960,7 @@ func TestMSSQL(t *testing.T) {
columns := queryResult.Tables[0].Rows[0] columns := queryResult.Tables[0].Rows[0]
//Should be in milliseconds //Should be in milliseconds
So(columns[0].(int64), ShouldEqual, int64(dt.Unix()*1000)) So(columns[0].(int64), ShouldEqual, dt.Unix()*1000)
}) })
Convey("When doing an annotation query with a time column in epoch millisecond format should return ms", func() { Convey("When doing an annotation query with a time column in epoch millisecond format should return ms", func() {
......
...@@ -132,8 +132,8 @@ func TestMySQL(t *testing.T) { ...@@ -132,8 +132,8 @@ func TestMySQL(t *testing.T) {
So(column[7].(float64), ShouldEqual, 1.11) So(column[7].(float64), ShouldEqual, 1.11)
So(column[8].(float64), ShouldEqual, 2.22) So(column[8].(float64), ShouldEqual, 2.22)
So(*column[9].(*float32), ShouldEqual, 3.33) So(*column[9].(*float32), ShouldEqual, 3.33)
So(column[10].(time.Time), ShouldHappenWithin, time.Duration(10*time.Second), time.Now()) So(column[10].(time.Time), ShouldHappenWithin, 10*time.Second, time.Now())
So(column[11].(time.Time), ShouldHappenWithin, time.Duration(10*time.Second), time.Now()) So(column[11].(time.Time), ShouldHappenWithin, 10*time.Second, time.Now())
So(column[12].(string), ShouldEqual, "11:11:11") So(column[12].(string), ShouldEqual, "11:11:11")
So(column[13].(int64), ShouldEqual, 2018) So(column[13].(int64), ShouldEqual, 2018)
So(*column[14].(*[]byte), ShouldHaveSameTypeAs, []byte{1}) So(*column[14].(*[]byte), ShouldHaveSameTypeAs, []byte{1})
...@@ -578,7 +578,7 @@ func TestMySQL(t *testing.T) { ...@@ -578,7 +578,7 @@ func TestMySQL(t *testing.T) {
So(queryResult.Error, ShouldBeNil) So(queryResult.Error, ShouldBeNil)
So(len(queryResult.Series), ShouldEqual, 1) So(len(queryResult.Series), ShouldEqual, 1)
So(queryResult.Series[0].Points[0][1].Float64, ShouldEqual, float64(float64(float32(tInitial.Unix())))*1e3) So(queryResult.Series[0].Points[0][1].Float64, ShouldEqual, float64(float32(tInitial.Unix()))*1e3)
}) })
Convey("When doing a metric query using epoch (float32 nullable) as time column and value column (float32 nullable) should return metric with time in milliseconds", func() { Convey("When doing a metric query using epoch (float32 nullable) as time column and value column (float32 nullable) should return metric with time in milliseconds", func() {
...@@ -600,7 +600,7 @@ func TestMySQL(t *testing.T) { ...@@ -600,7 +600,7 @@ func TestMySQL(t *testing.T) {
So(queryResult.Error, ShouldBeNil) So(queryResult.Error, ShouldBeNil)
So(len(queryResult.Series), ShouldEqual, 1) So(len(queryResult.Series), ShouldEqual, 1)
So(queryResult.Series[0].Points[0][1].Float64, ShouldEqual, float64(float64(float32(tInitial.Unix())))*1e3) So(queryResult.Series[0].Points[0][1].Float64, ShouldEqual, float64(float32(tInitial.Unix()))*1e3)
}) })
Convey("When doing a metric query grouping by time and select metric column should return correct series", func() { Convey("When doing a metric query grouping by time and select metric column should return correct series", func() {
...@@ -817,7 +817,7 @@ func TestMySQL(t *testing.T) { ...@@ -817,7 +817,7 @@ func TestMySQL(t *testing.T) {
columns := queryResult.Tables[0].Rows[0] columns := queryResult.Tables[0].Rows[0]
//Should be in milliseconds //Should be in milliseconds
So(columns[0].(int64), ShouldEqual, int64(dt.Unix()*1000)) So(columns[0].(int64), ShouldEqual, dt.Unix()*1000)
}) })
Convey("When doing an annotation query with a time column in epoch millisecond format should return ms", func() { Convey("When doing an annotation query with a time column in epoch millisecond format should return ms", func() {
......
...@@ -512,7 +512,7 @@ func TestPostgres(t *testing.T) { ...@@ -512,7 +512,7 @@ func TestPostgres(t *testing.T) {
So(queryResult.Error, ShouldBeNil) So(queryResult.Error, ShouldBeNil)
So(len(queryResult.Series), ShouldEqual, 1) So(len(queryResult.Series), ShouldEqual, 1)
So(queryResult.Series[0].Points[0][1].Float64, ShouldEqual, float64(float64(float32(tInitial.Unix())))*1e3) So(queryResult.Series[0].Points[0][1].Float64, ShouldEqual, float64(float32(tInitial.Unix()))*1e3)
}) })
Convey("When doing a metric query using epoch (float32 nullable) as time column and value column (float32 nullable) should return metric with time in milliseconds", func() { Convey("When doing a metric query using epoch (float32 nullable) as time column and value column (float32 nullable) should return metric with time in milliseconds", func() {
...@@ -534,7 +534,7 @@ func TestPostgres(t *testing.T) { ...@@ -534,7 +534,7 @@ func TestPostgres(t *testing.T) {
So(queryResult.Error, ShouldBeNil) So(queryResult.Error, ShouldBeNil)
So(len(queryResult.Series), ShouldEqual, 1) So(len(queryResult.Series), ShouldEqual, 1)
So(queryResult.Series[0].Points[0][1].Float64, ShouldEqual, float64(float64(float32(tInitial.Unix())))*1e3) So(queryResult.Series[0].Points[0][1].Float64, ShouldEqual, float64(float32(tInitial.Unix()))*1e3)
}) })
Convey("When doing a metric query grouping by time and select metric column should return correct series", func() { Convey("When doing a metric query grouping by time and select metric column should return correct series", func() {
...@@ -721,7 +721,7 @@ func TestPostgres(t *testing.T) { ...@@ -721,7 +721,7 @@ func TestPostgres(t *testing.T) {
columns := queryResult.Tables[0].Rows[0] columns := queryResult.Tables[0].Rows[0]
//Should be in milliseconds //Should be in milliseconds
So(columns[0].(int64), ShouldEqual, int64(dt.Unix()*1000)) So(columns[0].(int64), ShouldEqual, dt.Unix()*1000)
}) })
Convey("When doing an annotation query with a time column in epoch second format (int) should return ms", func() { Convey("When doing an annotation query with a time column in epoch second format (int) should return ms", func() {
...@@ -751,7 +751,7 @@ func TestPostgres(t *testing.T) { ...@@ -751,7 +751,7 @@ func TestPostgres(t *testing.T) {
columns := queryResult.Tables[0].Rows[0] columns := queryResult.Tables[0].Rows[0]
//Should be in milliseconds //Should be in milliseconds
So(columns[0].(int64), ShouldEqual, int64(dt.Unix()*1000)) So(columns[0].(int64), ShouldEqual, dt.Unix()*1000)
}) })
Convey("When doing an annotation query with a time column in epoch millisecond format should return ms", func() { Convey("When doing an annotation query with a time column in epoch millisecond format should return ms", func() {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment