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

Multi-batch write testing on a single-node

pull/1671/head
Philip O'Toole 2015-02-21 12:21:34 -08:00
parent 0fc9a31ed6
commit 22f3b246cd
1 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
cmd/influxd/server_integration_test.go
View File

@ -543,3 +543,21 @@ func Test_Server5NodeLargeBatchIntegration(t *testing.T) {
write(t, testName, nodes, createBatch(batchSize, "foo", "bar", "cpu", map[string]string{"host": "server01"}))
simpleCountQuery(t, "single node large batch", nodes, `select count(value) from "foo"."bar".cpu`, "value", batchSize)
}
func Test_ServerMultiLargeBatchIntegration(t *testing.T) {
if testing.Short() {
t.Skip()
}
nNodes := 1
nBatches := 5
basePort := 8690
testName := "single node multi batch"
nodes := createCombinedNodeCluster(t, testName, nNodes, basePort)
createDatabase(t, testName, nodes, "foo")
createRetentionPolicy(t, testName, nodes, "foo", "bar")
for i := 0; i < nBatches; i++ {
write(t, testName, nodes, createBatch(batchSize, "foo", "bar", "cpu", map[string]string{"host": "server01"}))
}
simpleCountQuery(t, "single node large batch", nodes, `select count(value) from "foo"."bar".cpu`, "value", batchSize*int64(nBatches))
}