johanels/akvorado
1
0
Fork 0
mirror of https://github.com/akvorado/akvorado.git synced 2025-12-12 06:24:10 +01:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

configure/clickhouse: run functional test twice

Browse Source
This commit is contained in:
Vincent Bernat
2022-04-02 11:19:41 +02:00
parent ddee39f06c
commit cb541fd6e9
1 changed files with 21 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
configure/clickhouse/functional_test.go
View File

@@ -29,11 +29,6 @@ func TestRealClickHouse(t *testing.T) {
if err := ch.Start(); err != nil { if err := ch.Start(); err != nil {
t.Fatalf("Start() error:\n%+v", err) t.Fatalf("Start() error:\n%+v", err)
} }
defer func() {
if err := ch.Stop(); err != nil {
t.Fatalf("Stop() error:\n%+v", err)
}
}()
select { select {
case <-ch.migrationsDone: case <-ch.migrationsDone:
case <-time.After(3 * time.Second): case <-time.After(3 * time.Second):
@@ -78,4 +73,25 @@ func TestRealClickHouse(t *testing.T) {
if diff := helpers.Diff(got, expected); diff != "" { if diff := helpers.Diff(got, expected); diff != "" {
t.Fatalf("SHOW TABLES (-got, +want):\n%s", diff) t.Fatalf("SHOW TABLES (-got, +want):\n%s", diff)
} }
if err := ch.Stop(); err != nil {
t.Fatalf("Stop() error:\n%+v", err)
}
// Check we can run a second time
ch, err = New(r, configuration, Dependencies{
Daemon: daemon.NewMock(t),
HTTP: http.NewMock(t, r),
})
if err != nil {
t.Fatalf("New() error:\n%+v", err)
}
if err := ch.Start(); err != nil {
t.Fatalf("Start() error:\n%+v", err)
}
select {
case <-ch.migrationsDone:
case <-time.After(3 * time.Second):
t.Fatalf("Migrations not done")
}
ch.Stop()
} }