feat(outputs.redistimeseries): Add integration test (#11529)

plugins/outputs/redistimeseries/redistimeseries_test.go

@@ -1,9 +1,13 @@
 package redistimeseries
 
 import (
+	"fmt"
+	"testing"
+
+	"github.com/docker/go-connections/nat"
 	"github.com/influxdata/telegraf/testutil"
 	"github.com/stretchr/testify/require"
-	"testing"
+	"github.com/testcontainers/testcontainers-go/wait"
 )
 
 func TestConnectAndWrite(t *testing.T) {
@@ -24,3 +28,26 @@ func TestConnectAndWrite(t *testing.T) {
 	err = redis.Write(testutil.MockMetrics())
 	require.NoError(t, err)
 }
+
+func TestConnectAndWriteIntegration(t *testing.T) {
+	if testing.Short() {
+		t.Skip("Skipping integration test in short mode")
+	}
+	servicePort := "6379"
+	container := testutil.Container{
+		Image:        "redislabs/redistimeseries",
+		ExposedPorts: []string{servicePort},
+		WaitingFor:   wait.ForListeningPort(nat.Port(servicePort)),
+	}
+	require.NoError(t, container.Start(), "failed to start container")
+	defer func() {
+		require.NoError(t, container.Terminate(), "terminating container failed")
+	}()
+	redis := &RedisTimeSeries{
+		Address: fmt.Sprintf("%s:%s", container.Address, container.Ports[servicePort]),
+	}
+	// Verify that we can connect to the RedisTimeSeries server
+	require.NoError(t, redis.Connect())
+	// Verify that we can successfully write data to the RedisTimeSeries server
+	require.NoError(t, redis.Write(testutil.MockMetrics()))
+}