prow/kube/client.go
func (c *Client) requestRetryStream(r *request) (io.ReadCloser, error) {
	if c.fake && r.deckPath == "" {
		return nil, nil
	}
	resp, err := c.retry(r)
	if err != nil {
		return nil, err
	}
	if resp.StatusCode == 409 {
		return nil, NewConflictError(fmt.Errorf("body cannot be streamed"))
	} else if resp.StatusCode < 200 || resp.StatusCode > 299 {
		return nil, fmt.Errorf("response has status \"%s\"", resp.Status)
	}
	return resp.Body, nil
}
func (c *Client) requestRetryStream(r *request) (io.ReadCloser, error) {
	if c.fake && r.deckPath == "" {
		return nil, nil
	}
	resp, err := c.retry(r)
	if err != nil {
		return nil, err
	}
	if resp.StatusCode == 409 {
		return nil, NewConflictError(fmt.Errorf("body cannot be streamed"))
	} else if resp.StatusCode < 200 || resp.StatusCode > 299 {
		return nil, fmt.Errorf("response has status \"%s\"", resp.Status)
	}
	return resp.Body, nil
}
func ( c * Client ) requestRetryStream ( r * request ) ( io . ReadCloser , error ) { if c . fake && r . deckPath == " " { return nil , nil } resp , err := c . retry ( r ) if err != nil { return nil , err } if resp . StatusCode == 409 { return nil , NewConflictError ( fmt . Errorf ( " " ) ) } else if resp . StatusCode < 200 || resp . StatusCode > 299 { return nil , fmt . Errorf ( " \" \" " , resp . Status ) } return resp . Body , nil }
// Retry on transport failures. Does not retry on 500s.
Retry on transport failures . Does not retry on 500s .