Function waitForIndexing

search_resp_test.go:359–372

(t *testing.T, client *redis.Client, index string, expectedDocs int)

}

func waitForIndexing(t *testing.T, client *redis.Client, index string, expectedDocs int) {
	t.Helper()
	ctx := context.Background()
	for i := 0; i < 100; i++ {
		info, err := client.FTInfo(ctx, index).Result()
		if err != nil {
			t.Fatalf("FTInfo failed: %v", err)
		}
		if info.NumDocs >= expectedDocs {
			return
		}
	}
	t.Fatalf("Timeout waiting for indexing")
}