Function WaitForIndexing

search_test.go:23–36

WaitForIndexing polls FT.INFO until the index has finished both its initial indexing pass and any background cleaning. Cleaning can briefly report 1 right after index creation (e.g. for HNSW vector indexes) while background setup is in progress, so callers that immediately assert on FT.INFO fields w

(c *redis.Client, index string)

// background setup is in progress, so callers that immediately assert on
// FT.INFO fields would otherwise be flaky.
func WaitForIndexing(c *redis.Client, index string) {
	deadline := time.Now().Add(30 * time.Second)
	for {
		res, err := c.FTInfo(context.Background(), index).Result()
		Expect(err).NotTo(HaveOccurred())
		if res.Indexing == 0 && res.Cleaning == 0 {
			return
		}
		if time.Now().After(deadline) {
			Fail(fmt.Sprintf("WaitForIndexing(%q) timed out: indexing=%d cleaning=%d", index, res.Indexing, res.Cleaning))
		}
		time.Sleep(100 * time.Millisecond)
	}
}

func encodeFloat32Vector(vec []float32) []byte {
	buf := new(bytes.Buffer)