dom
/
telegraf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

fix tests, remove debug prints

This commit is contained in:
JP 2015-08-13 20:42:57 -05:00
parent 3145a732f2
commit 0ae5075cc9
2 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
outputs/datadog/datadog.go
View File

@ -78,9 +78,7 @@ func (d *Datadog) Write(bp client.BatchPoints) error {
} }
req.Header.Add("Content-Type", "application/json") req.Header.Add("Content-Type", "application/json")
fmt.Printf("making POST call\n")
resp, err := d.client.Do(req) resp, err := d.client.Do(req)
fmt.Printf("POST call made, err is: %+v\n", err)
defer resp.Body.Close() defer resp.Body.Close()
if err != nil { if err != nil {
return fmt.Errorf("error POSTing metrics, %s\n", err.Error()) return fmt.Errorf("error POSTing metrics, %s\n", err.Error())

16
outputs/datadog/datadog_test.go
View File

@ -30,7 +30,9 @@ func testData() client.BatchPoints {
bp.Time = time.Now() bp.Time = time.Now()
bp.Tags = map[string]string{"tag1": "value1"} bp.Tags = map[string]string{"tag1": "value1"}
bp.Points = []client.Point{ bp.Points = []client.Point{
Fields: map[string]interface{}{"value": 1.0}, {
Fields: map[string]interface{}{"value": 1.0},
},
} }
return bp return bp
} }
@ -43,7 +45,10 @@ func TestUriOverride(t *testing.T) {
defer ts.Close() defer ts.Close()
d := NewDatadog(ts.URL) d := NewDatadog(ts.URL)
err := d.Write(testData()) d.Apikey = "123456"
err := d.Connect()
require.NoError(t, err)
err = d.Write(testData())
require.NoError(t, err) require.NoError(t, err)
} }
@ -59,11 +64,14 @@ func TestBadStatusCode(t *testing.T) {
defer ts.Close() defer ts.Close()
d := NewDatadog(ts.URL) d := NewDatadog(ts.URL)
err := d.Write(testData()) d.Apikey = "123456"
err := d.Connect()
require.NoError(t, err)
err = d.Write(testData())
if err == nil { if err == nil {
t.Errorf("error expected but none returned") t.Errorf("error expected but none returned")
} else { } else {
require.EqualError(t, fmt.Errorf("error POSTing metrics, "), err.Error()) require.EqualError(t, fmt.Errorf("received bad status code, 500\n"), err.Error())
} }
} }