fix k8s api memory leak (#2166)

util/kubernetes/api/response.go

@@ -59,7 +59,10 @@ func (r *Response) Into(data interface{}) error {
 }
 
 func (r *Response) Close() error {
-	return r.res.Body.Close()
+	if r.res != nil {
+		return r.res.Body.Close()
+	}
+	return nil
 }
 
 func newResponse(res *http.Response, err error) *Response {

util/kubernetes/client/client.go

@@ -64,15 +64,15 @@ func (c *client) Create(r *Resource, opts ...CreateOption) error {
 	if err := renderTemplate(r.Kind, b, r.Value); err != nil {
 		return err
 	}
-
+	resp := api.NewRequest(c.opts).
-	return api.NewRequest(c.opts).
 		Post().
 		SetHeader("Content-Type", "application/yaml").
 		Namespace(options.Namespace).
 		Resource(r.Kind).
 		Body(b).
-		Do().
+		Do()
-		Error()
+	resp.Close()
+	return resp.Error()
 }
 
 var (
@@ -160,8 +160,9 @@ func (c *client) Update(r *Resource, opts ...UpdateOption) error {
 	default:
 		return errors.New("unsupported resource")
 	}
-
+	resp := req.Do()
-	return req.Do().Error()
+	resp.Close()
+	return resp.Error()
 }
 
 // Delete removes API object
@@ -172,14 +173,14 @@ func (c *client) Delete(r *Resource, opts ...DeleteOption) error {
 	for _, o := range opts {
 		o(&options)
 	}
-
+	resp := api.NewRequest(c.opts).
-	return api.NewRequest(c.opts).
 		Delete().
 		Resource(r.Kind).
 		Name(r.Name).
 		Namespace(options.Namespace).
-		Do().
+		Do()
-		Error()
+	resp.Close()
+	return resp.Error()
 }
 
 // List lists API objects and stores the result in r