aboutsummaryrefslogtreecommitdiffstats
path: root/modules/indexer/issues/elasticsearch/elasticsearch_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'modules/indexer/issues/elasticsearch/elasticsearch_test.go')
-rw-r--r--modules/indexer/issues/elasticsearch/elasticsearch_test.go18
1 files changed, 5 insertions, 13 deletions
diff --git a/modules/indexer/issues/elasticsearch/elasticsearch_test.go b/modules/indexer/issues/elasticsearch/elasticsearch_test.go
index ffd85b1aa1..dc329c07dd 100644
--- a/modules/indexer/issues/elasticsearch/elasticsearch_test.go
+++ b/modules/indexer/issues/elasticsearch/elasticsearch_test.go
@@ -11,6 +11,8 @@ import (
"time"
"code.gitea.io/gitea/modules/indexer/issues/internal/tests"
+
+ "github.com/stretchr/testify/require"
)
func TestElasticsearchIndexer(t *testing.T) {
@@ -26,20 +28,10 @@ func TestElasticsearchIndexer(t *testing.T) {
}
}
- ok := false
- for i := 0; i < 60; i++ {
+ require.Eventually(t, func() bool {
resp, err := http.Get(url)
- if err == nil && resp.StatusCode == http.StatusOK {
- ok = true
- break
- }
- t.Logf("Waiting for elasticsearch to be up: %v", err)
- time.Sleep(time.Second)
- }
- if !ok {
- t.Fatalf("Failed to wait for elasticsearch to be up")
- return
- }
+ return err == nil && resp.StatusCode == http.StatusOK
+ }, time.Minute, time.Second, "Expected elasticsearch to be up")
indexer := NewIndexer(url, fmt.Sprintf("test_elasticsearch_indexer_%d", time.Now().Unix()))
defer indexer.Close()