Function queryWithTsForResp

dgraph/cmd/alpha/http_test.go:175–205

queryWithTsForResp query the dgraph and returns it's http response and result.

(inp queryInp)

// queryWithTsForResp query the dgraph and returns it's http response and result.
func queryWithTsForResp(inp queryInp) (string, *tsInfo, *http.Response, error) {
	params := make([]string, 0, 3)
	if inp.debug != "" {
		params = append(params, "debug="+inp.debug)
	}
	if inp.ts != 0 {
		params = append(params, fmt.Sprintf("startTs=%v", strconv.FormatUint(inp.ts, 10)))
		params = append(params, fmt.Sprintf("hash=%s", inp.hash))
	}
	if inp.respFmt != "" {
		params = append(params, fmt.Sprintf("respFormat=%s", inp.respFmt))
	}
	url := addr + "/query?" + strings.Join(params, "&")

	_, body, resp, err := runWithRetriesForResp("POST", inp.typ, url, inp.body)
	if err != nil {
		return "", nil, resp, err
	}

	var r res
	if err := json.Unmarshal(body, &r); err != nil {
		return "", nil, resp, err
	}
	startTs := r.Extensions.Txn.StartTs
	hash := r.Extensions.Txn.Hash

	// Remove the extensions
	r2 := res{Data: r.Data}
	output, err := json.Marshal(r2)
	return string(output), &tsInfo{ts: startTs, hash: hash}, resp, err
}

type mutationResponse struct {
	keys    []string