Function runWithRetriesForResp

dgraph/cmd/alpha/http_test.go:313–336

(method, contentType, url string, body string)

}

func runWithRetriesForResp(method, contentType, url string, body string) (
	*x.QueryResWithData, []byte, *http.Response, error) {

	req, err := createRequest(method, contentType, url, body)
	if err != nil {
		return nil, nil, nil, err
	}

	qr, respBody, resp, err := runRequest(req)
	if err != nil && strings.Contains(err.Error(), "Token is expired") {
		if err := token.refreshToken(); err != nil {
			return nil, nil, nil, err
		}

		// create a new request since the previous request would have been closed upon the err
		retryReq, err := createRequest(method, contentType, url, body)
		if err != nil {
			return nil, nil, resp, err
		}

		return runRequest(retryReq)
	}
	return qr, respBody, resp, err
}

func commitWithTs(mr mutationResponse, abort bool) error {
	url := addr + "/commit"