Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Fix opentsdb integration tests after rebase

pull/2202/head
Paul Dix 2015-04-07 11:49:41 -04:00 committed by Philip O'Toole
parent b353119f8e
commit 8a25683b92
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
cmd/influxd/server_integration_test.go
View File

@ -1769,7 +1769,7 @@ func Test_ServerOpenTSDBIntegration(t *testing.T) {
defer nodes.Close() defer nodes.Close()
createDatabase(t, testName, nodes, "opentsdb") createDatabase(t, testName, nodes, "opentsdb")
createRetentionPolicy(t, testName, nodes, "opentsdb", "raw") createRetentionPolicy(t, testName, nodes, "opentsdb", "raw", len(nodes))
// Connect to the graphite endpoint we just spun up // Connect to the graphite endpoint we just spun up
conn, err := net.Dial("tcp", o.ListenAddress(c.BindAddress)) conn, err := net.Dial("tcp", o.ListenAddress(c.BindAddress))
@ -1820,7 +1820,7 @@ func Test_ServerOpenTSDBIntegration_WithTags(t *testing.T) {
defer nodes.Close() defer nodes.Close()
createDatabase(t, testName, nodes, "opentsdb") createDatabase(t, testName, nodes, "opentsdb")
createRetentionPolicy(t, testName, nodes, "opentsdb", "raw") createRetentionPolicy(t, testName, nodes, "opentsdb", "raw", len(nodes))
// Connect to the graphite endpoint we just spun up // Connect to the graphite endpoint we just spun up
conn, err := net.Dial("tcp", o.ListenAddress(c.BindAddress)) conn, err := net.Dial("tcp", o.ListenAddress(c.BindAddress))
@ -1874,7 +1874,7 @@ func Test_ServerOpenTSDBIntegration_BadData(t *testing.T) {
defer nodes.Close() defer nodes.Close()
createDatabase(t, testName, nodes, "opentsdb") createDatabase(t, testName, nodes, "opentsdb")
createRetentionPolicy(t, testName, nodes, "opentsdb", "raw") createRetentionPolicy(t, testName, nodes, "opentsdb", "raw", len(nodes))
// Connect to the graphite endpoint we just spun up // Connect to the graphite endpoint we just spun up
conn, err := net.Dial("tcp", o.ListenAddress(c.BindAddress)) conn, err := net.Dial("tcp", o.ListenAddress(c.BindAddress))