From 043383a79b154aae5dcd50d17d168d52770c6a9e Mon Sep 17 00:00:00 2001 From: Josh Powers Date: Fri, 27 May 2022 10:37:39 -0600 Subject: [PATCH] test: migrate mcrouter to test-containers missed this during the memcached transition --- plugins/inputs/mcrouter/mcrouter_test.go | 21 +++++++++++++++++++-- 1 file changed, 19 insertions(+), 2 deletions(-) diff --git a/plugins/inputs/mcrouter/mcrouter_test.go b/plugins/inputs/mcrouter/mcrouter_test.go index f02f2b53d4b85..5e5adbc53d12e 100644 --- a/plugins/inputs/mcrouter/mcrouter_test.go +++ b/plugins/inputs/mcrouter/mcrouter_test.go @@ -2,10 +2,13 @@ package mcrouter import ( "bufio" + "fmt" "strings" "testing" + "github.com/docker/go-connections/nat" "github.com/stretchr/testify/require" + "github.com/testcontainers/testcontainers-go/wait" "github.com/influxdata/telegraf/testutil" ) @@ -49,13 +52,27 @@ func TestMcrouterGeneratesMetricsIntegration(t *testing.T) { t.Skip("Skipping integration test in short mode") } + servicePort := "11211" + container := testutil.Container{ + Image: "memcached", + ExposedPorts: []string{servicePort}, + WaitingFor: wait.ForListeningPort(nat.Port(servicePort)), + } + err := container.Start() + require.NoError(t, err, "failed to start container") + defer func() { + require.NoError(t, container.Terminate(), "terminating container failed") + }() + m := &Mcrouter{ - Servers: []string{"tcp://" + testutil.GetLocalHost()}, + Servers: []string{ + fmt.Sprintf("tcp://%s:%s", container.Address, container.Ports[servicePort]), + }, } var acc testutil.Accumulator - err := acc.GatherError(m.Gather) + err = acc.GatherError(m.Gather) require.NoError(t, err) intMetrics := []string{