Function WaitForPersistence

pindex_bleve_test.go:27–55

(pindex *cbgt.PIndex, docCount float64)

)

func WaitForPersistence(pindex *cbgt.PIndex, docCount float64) error {
	for i := 0; i < 100; i++ {
		stats := map[string]interface{}{
			"doc_count":           float64(0),
			"num_recs_to_persist": float64(0),
		}
		err := addPIndexStats(pindex, stats)
		if err != nil {
			return fmt.Errorf("expected nil addPIndexStats err, got: %v", err)
		}
		dv, ok := stats["doc_count"]
		if ok {
			dc, ok := dv.(float64)
			if ok && dc == docCount {
				v, ok1 := stats["num_recs_to_persist"]
				if ok1 {
					nrtp, ok1 := v.(float64)
					if ok1 && nrtp <= 0.0 {
						return nil
					}
				}
			}

		}

		time.Sleep(50 * time.Millisecond)
	}
	return fmt.Errorf("persistence took too long!")
}

func TestManagerRestart(t *testing.T) {
	emptyDir, _ := ioutil.TempDir("./tmp", "test")