From 6b67fedfdc340085a3e10963c49cbc91033e0a50 Mon Sep 17 00:00:00 2001
From: Daniel Nelson <daniel.nelson@influxdb.com>
Date: Fri, 13 Oct 2017 11:30:30 -0700
Subject: [PATCH] Remove timing sensitive riemann test
---
plugins/outputs/riemann/riemann_test.go | 51 -------------------------
1 file changed, 51 deletions(-)
diff --git a/plugins/outputs/riemann/riemann_test.go b/plugins/outputs/riemann/riemann_test.go
index 0b7c8540..61b7b379 100644
--- a/plugins/outputs/riemann/riemann_test.go
+++ b/plugins/outputs/riemann/riemann_test.go
@@ -1,14 +1,11 @@
package riemann
import (
- "fmt"
"testing"
"time"
"github.com/amir/raidman"
- "github.com/influxdata/telegraf"
"github.com/influxdata/telegraf/metric"
- "github.com/influxdata/telegraf/testutil"
"github.com/stretchr/testify/require"
)
@@ -162,51 +159,3 @@ func TestStateEvents(t *testing.T) {
}
require.Equal(t, expectedEvent, events[0])
}
-
-func TestConnectAndWrite(t *testing.T) {
- if testing.Short() {
- t.Skip("Skipping integration test in short mode")
- }
-
- r := &Riemann{
- URL: fmt.Sprintf("tcp://%s:5555", testutil.GetLocalHost()),
- TTL: 15.0,
- Separator: "/",
- MeasurementAsAttribute: false,
- StringAsState: true,
- DescriptionText: "metrics from telegraf",
- Tags: []string{"docker"},
- }
-
- err := r.Connect()
- require.NoError(t, err)
-
- err = r.Write(testutil.MockMetrics())
- require.NoError(t, err)
-
- metrics := make([]telegraf.Metric, 0)
- metrics = append(metrics, testutil.TestMetric(2))
- metrics = append(metrics, testutil.TestMetric(3.456789))
- metrics = append(metrics, testutil.TestMetric(uint(0)))
- metrics = append(metrics, testutil.TestMetric("ok"))
- metrics = append(metrics, testutil.TestMetric("running"))
- err = r.Write(metrics)
- require.NoError(t, err)
-
- // are there any "docker" tagged events in Riemann?
- events, err := r.client.Query(`tagged "docker"`)
- require.NoError(t, err)
- require.NotZero(t, len(events))
-
- // get Riemann events with state = "running", should be 1 event
- events, err = r.client.Query(`state = "running"`)
- require.NoError(t, err)
- require.Len(t, events, 1)
-
- // is event as expected?
- require.Equal(t, []string{"docker", "value1"}, events[0].Tags)
- require.Equal(t, "running", events[0].State)
- require.Equal(t, "test1/value", events[0].Service)
- require.Equal(t, "metrics from telegraf", events[0].Description)
- require.Equal(t, map[string]string{"tag1": "value1"}, events[0].Attributes)
-}
--
GitLab