forked from mirror/client_golang
Replace with the standard library constant.
Signed-off-by: johncming <johncming@yahoo.com>
This commit is contained in:
parent
aea1b33289
commit
32a545bf61
|
@ -117,8 +117,6 @@ func marshalPointJSONIsEmpty(ptr unsafe.Pointer) bool {
|
||||||
}
|
}
|
||||||
|
|
||||||
const (
|
const (
|
||||||
statusAPIError = 422
|
|
||||||
|
|
||||||
apiPrefix = "/api/v1"
|
apiPrefix = "/api/v1"
|
||||||
|
|
||||||
epAlerts = apiPrefix + "/alerts"
|
epAlerts = apiPrefix + "/alerts"
|
||||||
|
@ -943,7 +941,7 @@ type apiResponse struct {
|
||||||
|
|
||||||
func apiError(code int) bool {
|
func apiError(code int) bool {
|
||||||
// These are the codes that Prometheus sends when it returns an error.
|
// These are the codes that Prometheus sends when it returns an error.
|
||||||
return code == statusAPIError || code == http.StatusBadRequest
|
return code == http.StatusUnprocessableEntity || code == http.StatusBadRequest
|
||||||
}
|
}
|
||||||
|
|
||||||
func errorTypeAndMsgFor(resp *http.Response) (ErrorType, string) {
|
func errorTypeAndMsgFor(resp *http.Response) (ErrorType, string) {
|
||||||
|
|
|
@ -84,7 +84,7 @@ func (c *apiTestClient) Do(ctx context.Context, req *http.Request) (*http.Respon
|
||||||
if test.inStatusCode != 0 {
|
if test.inStatusCode != 0 {
|
||||||
resp.StatusCode = test.inStatusCode
|
resp.StatusCode = test.inStatusCode
|
||||||
} else if test.inErr != nil {
|
} else if test.inErr != nil {
|
||||||
resp.StatusCode = statusAPIError
|
resp.StatusCode = http.StatusUnprocessableEntity
|
||||||
} else {
|
} else {
|
||||||
resp.StatusCode = http.StatusOK
|
resp.StatusCode = http.StatusOK
|
||||||
}
|
}
|
||||||
|
@ -1118,7 +1118,7 @@ func (c *testClient) Do(ctx context.Context, req *http.Request) (*http.Response,
|
||||||
func TestAPIClientDo(t *testing.T) {
|
func TestAPIClientDo(t *testing.T) {
|
||||||
tests := []apiClientTest{
|
tests := []apiClientTest{
|
||||||
{
|
{
|
||||||
code: statusAPIError,
|
code: http.StatusUnprocessableEntity,
|
||||||
response: &apiResponse{
|
response: &apiResponse{
|
||||||
Status: "error",
|
Status: "error",
|
||||||
Data: json.RawMessage(`null`),
|
Data: json.RawMessage(`null`),
|
||||||
|
@ -1132,7 +1132,7 @@ func TestAPIClientDo(t *testing.T) {
|
||||||
expectedBody: `null`,
|
expectedBody: `null`,
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
code: statusAPIError,
|
code: http.StatusUnprocessableEntity,
|
||||||
response: &apiResponse{
|
response: &apiResponse{
|
||||||
Status: "error",
|
Status: "error",
|
||||||
Data: json.RawMessage(`"test"`),
|
Data: json.RawMessage(`"test"`),
|
||||||
|
@ -1177,7 +1177,7 @@ func TestAPIClientDo(t *testing.T) {
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
code: statusAPIError,
|
code: http.StatusUnprocessableEntity,
|
||||||
response: "bad json",
|
response: "bad json",
|
||||||
expectedErr: &Error{
|
expectedErr: &Error{
|
||||||
Type: ErrBadResponse,
|
Type: ErrBadResponse,
|
||||||
|
@ -1185,7 +1185,7 @@ func TestAPIClientDo(t *testing.T) {
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
code: statusAPIError,
|
code: http.StatusUnprocessableEntity,
|
||||||
response: &apiResponse{
|
response: &apiResponse{
|
||||||
Status: "success",
|
Status: "success",
|
||||||
Data: json.RawMessage(`"test"`),
|
Data: json.RawMessage(`"test"`),
|
||||||
|
@ -1196,7 +1196,7 @@ func TestAPIClientDo(t *testing.T) {
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
code: statusAPIError,
|
code: http.StatusUnprocessableEntity,
|
||||||
response: &apiResponse{
|
response: &apiResponse{
|
||||||
Status: "success",
|
Status: "success",
|
||||||
Data: json.RawMessage(`"test"`),
|
Data: json.RawMessage(`"test"`),
|
||||||
|
|
Loading…
Reference in New Issue