Function InvokeApiWithKvData

api/handler/common.go:38–80

(method, uri string, args map[string]string, respStruct interface{}, header ...http.Header)

}

func InvokeApiWithKvData(method, uri string, args map[string]string, respStruct interface{}, header ...http.Header) (err error) {
	var req *http.Request
	switch method {
	case http.MethodGet:
		req, err = http.NewRequest(method, uri, nil)
		if err != nil {
			return fmt.Errorf("NewRequest failed: %v", err)
		}
		param := req.URL.Query()
		for k, v := range args {
			param.Add(k, v)
		}
		req.URL.RawQuery = param.Encode()
	case http.MethodPost:
		formData := url.Values{}
		for k, v := range args {
			formData.Add(k, v)
		}
		req, err = http.NewRequest(method, uri, strings.NewReader(formData.Encode()))
		if err != nil {
			return fmt.Errorf("NewRequest failed: %v", err)
		}
		req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
	default:
		return fmt.Errorf("unsupported method: %v", method)
	}
	if len(header) != 0 {
		for k, s := range header[0] {
			req.Header[k] = s
		}
	}
	client := &http.Client{}
	resp, err := client.Do(req)
	if err != nil {
		return fmt.Errorf("send request failed: %v", err)
	}
	defer resp.Body.Close()
	if err := handleNomadResponse(resp.Body, resp.StatusCode, &respStruct); nil != err {
		return fmt.Errorf("parse response failed: %v", err)
	}

	return nil
}

func InvokePostApiWithJson(url string, reqJson []byte, respStruct interface{}) error {
	resp, err := http.Post(url, "application/json", bytes.NewReader(reqJson))