CL-Softwares
/
telegraf
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

test: update integration test occurrences (#12085)

This commit is contained in:
Joshua Powers 2022-10-21 14:18:15 -06:00 committed by GitHub
parent b3b72aea86
commit d45c7c44c7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
plugins/inputs/pgbouncer/pgbouncer_test.go
View File

@ -26,7 +26,7 @@ func TestPgBouncerGeneratesMetricsIntegration(t *testing.T) {
Env: map[string]string{ Env: map[string]string{
"POSTGRES_HOST_AUTH_METHOD": "trust", "POSTGRES_HOST_AUTH_METHOD": "trust",
}, },
WaitingFor: wait.ForLog("database system is ready to accept connections"), WaitingFor: wait.ForLog("database system is ready to accept connections").WithOccurrence(2),
} }
err := backend.Start() err := backend.Start()
require.NoError(t, err, "failed to start container") require.NoError(t, err, "failed to start container")

6
plugins/inputs/sql/sql_test.go
View File

@ -55,7 +55,7 @@ func TestMariaDBIntegration(t *testing.T) {
"/docker-entrypoint-initdb.d": testdata, "/docker-entrypoint-initdb.d": testdata,
}, },
WaitingFor: wait.ForAll( WaitingFor: wait.ForAll(
wait.ForLog("Buffer pool(s) load completed at"), wait.ForLog("mariadbd: ready for connections.").WithOccurrence(2),
wait.ForListeningPort(nat.Port(port)), wait.ForListeningPort(nat.Port(port)),
), ),
} }
@ -162,7 +162,7 @@ func TestPostgreSQLIntegration(t *testing.T) {
"/docker-entrypoint-initdb.d": testdata, "/docker-entrypoint-initdb.d": testdata,
}, },
WaitingFor: wait.ForAll( WaitingFor: wait.ForAll(
wait.ForLog("database system is ready to accept connections"), wait.ForLog("database system is ready to accept connections").WithOccurrence(2),
wait.ForListeningPort(nat.Port(port)), wait.ForListeningPort(nat.Port(port)),
), ),
} }
@ -266,7 +266,7 @@ func TestClickHouseIntegration(t *testing.T) {
WaitingFor: wait.ForAll( WaitingFor: wait.ForAll(
wait.NewHTTPStrategy("/").WithPort(nat.Port("8123")), wait.NewHTTPStrategy("/").WithPort(nat.Port("8123")),
wait.ForListeningPort(nat.Port(port)), wait.ForListeningPort(nat.Port(port)),
wait.ForLog("Saved preprocessed configuration to '/var/lib/clickhouse/preprocessed_configs/users.xml'"), wait.ForLog("Saved preprocessed configuration to '/var/lib/clickhouse/preprocessed_configs/users.xml'.").WithOccurrence(2),
), ),
} }
err = container.Start() err = container.Start()

2
plugins/inputs/supervisor/supervisor_test.go
View File

@ -143,7 +143,7 @@ func TestIntegration_BasicGathering(t *testing.T) {
"/etc/supervisor/supervisord.conf": supervisorConfig, "/etc/supervisor/supervisord.conf": supervisorConfig,
}, },
WaitingFor: wait.ForAll( WaitingFor: wait.ForAll(
wait.ForLog("supervisord started with pid"), wait.ForLog("entered RUNNING state").WithOccurrence(6),
wait.ForListeningPort(nat.Port(supervisorPort)), wait.ForListeningPort(nat.Port(supervisorPort)),
), ),
} }

4
plugins/outputs/mongodb/mongodb_test.go
View File

@ -69,7 +69,7 @@ func TestConnectAndWriteIntegrationSCRAMAuth(t *testing.T) {
}, },
WaitingFor: wait.ForAll( WaitingFor: wait.ForAll(
wait.NewHTTPStrategy("/").WithPort(nat.Port(servicePort)), wait.NewHTTPStrategy("/").WithPort(nat.Port(servicePort)),
wait.ForLog("Waiting for connections"), wait.ForLog("Waiting for connections").WithOccurrence(2),
), ),
} }
err = container.Start() err = container.Start()
@ -174,7 +174,7 @@ func TestConnectAndWriteIntegrationX509Auth(t *testing.T) {
}, },
WaitingFor: wait.ForAll( WaitingFor: wait.ForAll(
wait.NewHTTPStrategy("/").WithPort(nat.Port(servicePort)), wait.NewHTTPStrategy("/").WithPort(nat.Port(servicePort)),
wait.ForLog("Waiting for connections"), wait.ForLog("Waiting for connections").WithOccurrence(2),
), ),
} }
err = container.Start() err = container.Start()