prow/kube/dry_run_client.go
func (c *dryRunProwJobClient) requestRetry(path string, query map[string]string) ([]byte, error) {
	resp, err := c.retry(path, query)
	if err != nil {
		return nil, err
	}

	defer resp.Body.Close()
	rb, err := ioutil.ReadAll(resp.Body)
	if err != nil {
		return nil, err
	}
	if resp.StatusCode == 404 {
		return nil, &kapierrors.StatusError{ErrStatus: metav1.Status{
			Status: metav1.StatusFailure,
			Code:   http.StatusNotFound,
			Reason: metav1.StatusReasonNotFound,
		}}
	} else if resp.StatusCode == 409 {
		return nil, &kapierrors.StatusError{ErrStatus: metav1.Status{
			Status: metav1.StatusFailure,
			Code:   http.StatusConflict,
			Reason: metav1.StatusReasonAlreadyExists,
		}}
	} else if resp.StatusCode == 422 {
		return nil, &kapierrors.StatusError{ErrStatus: metav1.Status{
			Status: metav1.StatusFailure,
			Code:   http.StatusUnprocessableEntity,
			Reason: metav1.StatusReasonInvalid,
		}}
	} else if resp.StatusCode < 200 || resp.StatusCode > 299 {
		return nil, fmt.Errorf("response has status \"%s\" and body \"%s\"", resp.Status, string(rb))
	}
	return rb, nil
}
func (c *dryRunProwJobClient) requestRetry(path string, query map[string]string) ([]byte, error) {
	resp, err := c.retry(path, query)
	if err != nil {
		return nil, err
	}

	defer resp.Body.Close()
	rb, err := ioutil.ReadAll(resp.Body)
	if err != nil {
		return nil, err
	}
	if resp.StatusCode == 404 {
		return nil, &kapierrors.StatusError{ErrStatus: metav1.Status{
			Status: metav1.StatusFailure,
			Code:   http.StatusNotFound,
			Reason: metav1.StatusReasonNotFound,
		}}
	} else if resp.StatusCode == 409 {
		return nil, &kapierrors.StatusError{ErrStatus: metav1.Status{
			Status: metav1.StatusFailure,
			Code:   http.StatusConflict,
			Reason: metav1.StatusReasonAlreadyExists,
		}}
	} else if resp.StatusCode == 422 {
		return nil, &kapierrors.StatusError{ErrStatus: metav1.Status{
			Status: metav1.StatusFailure,
			Code:   http.StatusUnprocessableEntity,
			Reason: metav1.StatusReasonInvalid,
		}}
	} else if resp.StatusCode < 200 || resp.StatusCode > 299 {
		return nil, fmt.Errorf("response has status \"%s\" and body \"%s\"", resp.Status, string(rb))
	}
	return rb, nil
}
func ( c * dryRunProwJobClient ) requestRetry ( path string , query map [ string ] string ) ( [ ] byte , error ) { resp , err := c . retry ( path , query ) if err != nil { return nil , err } defer resp . Body . Close ( ) rb , err := ioutil . ReadAll ( resp . Body ) if err != nil { return nil , err } if resp . StatusCode == 404 { return nil , & kapierrors . StatusError { ErrStatus : metav1 . Status { Status : metav1 . StatusFailure , Code : http . StatusNotFound , Reason : metav1 . StatusReasonNotFound , } } } else if resp . StatusCode == 409 { return nil , & kapierrors . StatusError { ErrStatus : metav1 . Status { Status : metav1 . StatusFailure , Code : http . StatusConflict , Reason : metav1 . StatusReasonAlreadyExists , } } } else if resp . StatusCode == 422 { return nil , & kapierrors . StatusError { ErrStatus : metav1 . Status { Status : metav1 . StatusFailure , Code : http . StatusUnprocessableEntity , Reason : metav1 . StatusReasonInvalid , } } } else if resp . StatusCode < 200 || resp . StatusCode > 299 { return nil , fmt . Errorf ( " \" \" \" \" " , resp . Status , string ( rb ) ) } return rb , nil }
// Retry on transport failures. Does not retry on 500s.
Retry on transport failures . Does not retry on 500s .