Function PollTillPassOrTimeout

dgraphapi/json.go:27–47

(gcli *GrpcClient, query, want string, timeout time.Duration)

)

func PollTillPassOrTimeout(gcli *GrpcClient, query, want string, timeout time.Duration) error {
	timer := time.NewTimer(timeout)

	for {
		resp, err := gcli.Query(query)
		if err != nil {
			return errors.Wrap(err, "error while query")
		}

		err = CompareJSON(want, string(resp.Json))
		if err == nil {
			return nil
		}
		select {
		case <-timer.C:
			return err
		default:
			time.Sleep(waitDurBeforeRetry)
		}
	}
}

// CompareJSON compares two JSON objects (passed as strings).
func CompareJSON(want, got string) error {