create adds the object to the cluster.
(obj KubeObject, mapping *meta.RESTMapping)
| 223 | |
| 224 | // create adds the object to the cluster. |
| 225 | func (c *KubeCluster) create(obj KubeObject, mapping *meta.RESTMapping) (KubeObject, error) { |
| 226 | meta := obj.GetObjectMeta() |
| 227 | req := c.Client.RESTClient.Post().Body(obj) |
| 228 | |
| 229 | setRequestObjectInfo(req, meta.GetNamespace(), mapping) |
| 230 | |
| 231 | runtimeObj, err := req.Do().Get() |
| 232 | if err != nil { |
| 233 | return nil, resourceError("create", meta.GetName(), meta.GetNamespace(), mapping, err) |
| 234 | } |
| 235 | |
| 236 | return AsKubeObject(runtimeObj) |
| 237 | } |
| 238 | |
| 239 | func (c *KubeCluster) deletePods(rc *kube.ReplicationController) error { |
| 240 | if rc == nil { |
no test coverage detected