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

OpenTSDB test problems, disabling output integration tests

This commit is contained in:
Cameron Sparr 2016-06-07 10:13:14 +01:00 committed by Vladimir Sagan
parent 393f03cd2f
commit 2d1423fc04
2 changed files with 36 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
Makefile
View File

@ -64,7 +64,6 @@ endif
docker run --name memcached -p "11211:11211" -d memcached docker run --name memcached -p "11211:11211" -d memcached
docker run --name postgres -p "5432:5432" -d postgres docker run --name postgres -p "5432:5432" -d postgres
docker run --name rabbitmq -p "15672:15672" -p "5672:5672" -d rabbitmq:3-management docker run --name rabbitmq -p "15672:15672" -p "5672:5672" -d rabbitmq:3-management
docker run --name opentsdb -p "4242:4242" -d petergrace/opentsdb-docker
docker run --name redis -p "6379:6379" -d redis docker run --name redis -p "6379:6379" -d redis
docker run --name aerospike -p "3000:3000" -d aerospike docker run --name aerospike -p "3000:3000" -d aerospike
docker run --name nsq -p "4150:4150" -d nsqio/nsq /nsqd docker run --name nsq -p "4150:4150" -d nsqio/nsq /nsqd
@ -79,7 +78,6 @@ docker-run-circle:
-e ADVERTISED_PORT=9092 \ -e ADVERTISED_PORT=9092 \
-p "2181:2181" -p "9092:9092" \ -p "2181:2181" -p "9092:9092" \
-d spotify/kafka -d spotify/kafka
docker run --name opentsdb -p "4242:4242" -d petergrace/opentsdb-docker
docker run --name aerospike -p "3000:3000" -d aerospike docker run --name aerospike -p "3000:3000" -d aerospike
docker run --name nsq -p "4150:4150" -d nsqio/nsq /nsqd docker run --name nsq -p "4150:4150" -d nsqio/nsq /nsqd
docker run --name mqtt -p "1883:1883" -d ncarlier/mqtt docker run --name mqtt -p "1883:1883" -d ncarlier/mqtt
@ -88,8 +86,8 @@ docker-run-circle:
# Kill all docker containers, ignore errors # Kill all docker containers, ignore errors
docker-kill: docker-kill:
-docker kill nsq aerospike redis opentsdb rabbitmq postgres memcached mysql kafka mqtt riemann snmp -docker kill nsq aerospike redis rabbitmq postgres memcached mysql kafka mqtt riemann snmp
-docker rm nsq aerospike redis opentsdb rabbitmq postgres memcached mysql kafka mqtt riemann snmp -docker rm nsq aerospike redis rabbitmq postgres memcached mysql kafka mqtt riemann snmp
# Run full unit tests using docker containers (includes setup and teardown) # Run full unit tests using docker containers (includes setup and teardown)
test: vet docker-kill docker-run test: vet docker-kill docker-run

69
plugins/outputs/opentsdb/opentsdb_test.go
View File

@ -3,9 +3,8 @@ package opentsdb
import ( import (
"reflect" "reflect"
"testing" "testing"
// "github.com/influxdata/telegraf/testutil"
"github.com/influxdata/telegraf/testutil" // "github.com/stretchr/testify/require"
"github.com/stretchr/testify/require"
) )
func TestBuildTagsTelnet(t *testing.T) { func TestBuildTagsTelnet(t *testing.T) {
@ -42,40 +41,40 @@ func TestBuildTagsTelnet(t *testing.T) {
} }
} }
func TestWrite(t *testing.T) { // func TestWrite(t *testing.T) {
if testing.Short() { // if testing.Short() {
t.Skip("Skipping integration test in short mode") // t.Skip("Skipping integration test in short mode")
} // }
o := &OpenTSDB{ // o := &OpenTSDB{
Host: testutil.GetLocalHost(), // Host: testutil.GetLocalHost(),
Port: 4242, // Port: 4242,
Prefix: "prefix.test.", // Prefix: "prefix.test.",
} // }
// Verify that we can connect to the OpenTSDB instance // // Verify that we can connect to the OpenTSDB instance
err := o.Connect() // err := o.Connect()
require.NoError(t, err) // require.NoError(t, err)
// Verify that we can successfully write data to OpenTSDB // // Verify that we can successfully write data to OpenTSDB
err = o.Write(testutil.MockMetrics()) // err = o.Write(testutil.MockMetrics())
require.NoError(t, err) // require.NoError(t, err)
// Verify postive and negative test cases of writing data // // Verify postive and negative test cases of writing data
metrics := testutil.MockMetrics() // metrics := testutil.MockMetrics()
metrics = append(metrics, testutil.TestMetric(float64(1.0), // metrics = append(metrics, testutil.TestMetric(float64(1.0),
"justametric.float")) // "justametric.float"))
metrics = append(metrics, testutil.TestMetric(int64(123456789), // metrics = append(metrics, testutil.TestMetric(int64(123456789),
"justametric.int")) // "justametric.int"))
metrics = append(metrics, testutil.TestMetric(uint64(123456789012345), // metrics = append(metrics, testutil.TestMetric(uint64(123456789012345),
"justametric.uint")) // "justametric.uint"))
metrics = append(metrics, testutil.TestMetric("Lorem Ipsum", // metrics = append(metrics, testutil.TestMetric("Lorem Ipsum",
"justametric.string")) // "justametric.string"))
metrics = append(metrics, testutil.TestMetric(float64(42.0), // metrics = append(metrics, testutil.TestMetric(float64(42.0),
"justametric.anotherfloat")) // "justametric.anotherfloat"))
metrics = append(metrics, testutil.TestMetric(float64(42.0), // metrics = append(metrics, testutil.TestMetric(float64(42.0),
"metric w/ specialchars")) // "metric w/ specialchars"))
err = o.Write(metrics) // err = o.Write(metrics)
require.NoError(t, err) // require.NoError(t, err)
} // }