added docker image unit test with OpenTSDB
This commit is contained in:
parent
e75b7d2e38
commit
58a2e5eb3b
|
@ -3,20 +3,11 @@ package opentsdb
|
|||
import (
|
||||
"reflect"
|
||||
"testing"
|
||||
)
|
||||
|
||||
var (
|
||||
fakeHost = "metrics.example.com"
|
||||
fakePort = 4242
|
||||
"github.com/influxdb/telegraf/testutil"
|
||||
"github.com/stretchr/testify/require"
|
||||
)
|
||||
|
||||
func fakeOpenTSDB() *OpenTSDB {
|
||||
var o OpenTSDB
|
||||
o.Host = fakeHost
|
||||
o.Port = fakePort
|
||||
return &o
|
||||
}
|
||||
|
||||
func TestBuildTagsTelnet(t *testing.T) {
|
||||
var tagtests = []struct {
|
||||
bpIn map[string]string
|
||||
|
@ -51,3 +42,21 @@ func TestBuildTagsTelnet(t *testing.T) {
|
|||
}
|
||||
}
|
||||
}
|
||||
func TestWrite(t *testing.T) {
|
||||
if testing.Short() {
|
||||
t.Skip("Skipping integration test in short mode")
|
||||
}
|
||||
|
||||
o := &OpenTSDB{
|
||||
Host: testutil.GetLocalHost() ,
|
||||
Port: 24242,
|
||||
}
|
||||
|
||||
// Verify that we can connect to the OpenTSDB instance
|
||||
err := o.Connect()
|
||||
require.NoError(t, err)
|
||||
|
||||
// Verify that we can successfully write data to OpenTSDB
|
||||
err = o.Write(testutil.MockBatchPoints())
|
||||
require.NoError(t, err)
|
||||
}
|
||||
|
|
|
@ -25,3 +25,9 @@ kafka:
|
|||
environment:
|
||||
ADVERTISED_HOST:
|
||||
ADVERTISED_PORT: 9092
|
||||
|
||||
opentsdb:
|
||||
image: lancope/opentsdb
|
||||
ports:
|
||||
- "24242:4242"
|
||||
|
||||
|
|
Loading…
Reference in New Issue