Fix UpdateStatus

pull/6/head
Chao Xu 2016-01-19 22:13:04 -08:00
parent 4e04a289d8
commit ee6f03f55a
15 changed files with 162 additions and 60 deletions

View File

@ -283,10 +283,17 @@ func (c *$.type|privatePlural$) Update($.type|private$ *$.type|raw$) (result *$.
` `
var updateStatusTemplate = ` var updateStatusTemplate = `
func (c *$.type|privatePlural$) UpdateStatus($.type|private$ *$.type|raw$) (*$.type|raw$, error) { func (c *$.type|privatePlural$) UpdateStatus($.type|private$ *$.type|raw$) (result *$.type|raw$, err error) {
result := &$.type|raw${} result = &$.type|raw${}
err := c.client.Put().Resource("$.type|privatePlural$").Name($.type|private$.Name).SubResource("status").Body($.type|private$).Do().Into(result) err = c.client.Put().
return result, err $if .namespaced$Namespace(c.ns).$end$
Resource("$.type|privatePlural$").
Name($.type|private$.Name).
SubResource("status").
Body($.type|private$).
Do().
Into(result)
return
} }
` `

View File

@ -80,10 +80,17 @@ func (c *testTypes) Update(testType *testgroup.TestType) (result *testgroup.Test
return return
} }
func (c *testTypes) UpdateStatus(testType *testgroup.TestType) (*testgroup.TestType, error) { func (c *testTypes) UpdateStatus(testType *testgroup.TestType) (result *testgroup.TestType, err error) {
result := &testgroup.TestType{} result = &testgroup.TestType{}
err := c.client.Put().Resource("testTypes").Name(testType.Name).SubResource("status").Body(testType).Do().Into(result) err = c.client.Put().
return result, err Namespace(c.ns).
Resource("testTypes").
Name(testType.Name).
SubResource("status").
Body(testType).
Do().
Into(result)
return
} }
// Delete takes name of the testType and deletes it. Returns an error if one occurs. // Delete takes name of the testType and deletes it. Returns an error if one occurs.

View File

@ -80,10 +80,17 @@ func (c *daemonSets) Update(daemonSet *extensions.DaemonSet) (result *extensions
return return
} }
func (c *daemonSets) UpdateStatus(daemonSet *extensions.DaemonSet) (*extensions.DaemonSet, error) { func (c *daemonSets) UpdateStatus(daemonSet *extensions.DaemonSet) (result *extensions.DaemonSet, err error) {
result := &extensions.DaemonSet{} result = &extensions.DaemonSet{}
err := c.client.Put().Resource("daemonSets").Name(daemonSet.Name).SubResource("status").Body(daemonSet).Do().Into(result) err = c.client.Put().
return result, err Namespace(c.ns).
Resource("daemonSets").
Name(daemonSet.Name).
SubResource("status").
Body(daemonSet).
Do().
Into(result)
return
} }
// Delete takes name of the daemonSet and deletes it. Returns an error if one occurs. // Delete takes name of the daemonSet and deletes it. Returns an error if one occurs.

View File

@ -80,10 +80,17 @@ func (c *deployments) Update(deployment *extensions.Deployment) (result *extensi
return return
} }
func (c *deployments) UpdateStatus(deployment *extensions.Deployment) (*extensions.Deployment, error) { func (c *deployments) UpdateStatus(deployment *extensions.Deployment) (result *extensions.Deployment, err error) {
result := &extensions.Deployment{} result = &extensions.Deployment{}
err := c.client.Put().Resource("deployments").Name(deployment.Name).SubResource("status").Body(deployment).Do().Into(result) err = c.client.Put().
return result, err Namespace(c.ns).
Resource("deployments").
Name(deployment.Name).
SubResource("status").
Body(deployment).
Do().
Into(result)
return
} }
// Delete takes name of the deployment and deletes it. Returns an error if one occurs. // Delete takes name of the deployment and deletes it. Returns an error if one occurs.

View File

@ -80,10 +80,17 @@ func (c *horizontalPodAutoscalers) Update(horizontalPodAutoscaler *extensions.Ho
return return
} }
func (c *horizontalPodAutoscalers) UpdateStatus(horizontalPodAutoscaler *extensions.HorizontalPodAutoscaler) (*extensions.HorizontalPodAutoscaler, error) { func (c *horizontalPodAutoscalers) UpdateStatus(horizontalPodAutoscaler *extensions.HorizontalPodAutoscaler) (result *extensions.HorizontalPodAutoscaler, err error) {
result := &extensions.HorizontalPodAutoscaler{} result = &extensions.HorizontalPodAutoscaler{}
err := c.client.Put().Resource("horizontalPodAutoscalers").Name(horizontalPodAutoscaler.Name).SubResource("status").Body(horizontalPodAutoscaler).Do().Into(result) err = c.client.Put().
return result, err Namespace(c.ns).
Resource("horizontalPodAutoscalers").
Name(horizontalPodAutoscaler.Name).
SubResource("status").
Body(horizontalPodAutoscaler).
Do().
Into(result)
return
} }
// Delete takes name of the horizontalPodAutoscaler and deletes it. Returns an error if one occurs. // Delete takes name of the horizontalPodAutoscaler and deletes it. Returns an error if one occurs.

View File

@ -80,10 +80,17 @@ func (c *ingresses) Update(ingress *extensions.Ingress) (result *extensions.Ingr
return return
} }
func (c *ingresses) UpdateStatus(ingress *extensions.Ingress) (*extensions.Ingress, error) { func (c *ingresses) UpdateStatus(ingress *extensions.Ingress) (result *extensions.Ingress, err error) {
result := &extensions.Ingress{} result = &extensions.Ingress{}
err := c.client.Put().Resource("ingresses").Name(ingress.Name).SubResource("status").Body(ingress).Do().Into(result) err = c.client.Put().
return result, err Namespace(c.ns).
Resource("ingresses").
Name(ingress.Name).
SubResource("status").
Body(ingress).
Do().
Into(result)
return
} }
// Delete takes name of the ingress and deletes it. Returns an error if one occurs. // Delete takes name of the ingress and deletes it. Returns an error if one occurs.

View File

@ -80,10 +80,17 @@ func (c *jobs) Update(job *extensions.Job) (result *extensions.Job, err error) {
return return
} }
func (c *jobs) UpdateStatus(job *extensions.Job) (*extensions.Job, error) { func (c *jobs) UpdateStatus(job *extensions.Job) (result *extensions.Job, err error) {
result := &extensions.Job{} result = &extensions.Job{}
err := c.client.Put().Resource("jobs").Name(job.Name).SubResource("status").Body(job).Do().Into(result) err = c.client.Put().
return result, err Namespace(c.ns).
Resource("jobs").
Name(job.Name).
SubResource("status").
Body(job).
Do().
Into(result)
return
} }
// Delete takes name of the job and deletes it. Returns an error if one occurs. // Delete takes name of the job and deletes it. Returns an error if one occurs.

View File

@ -75,10 +75,16 @@ func (c *namespaces) Update(namespace *api.Namespace) (result *api.Namespace, er
return return
} }
func (c *namespaces) UpdateStatus(namespace *api.Namespace) (*api.Namespace, error) { func (c *namespaces) UpdateStatus(namespace *api.Namespace) (result *api.Namespace, err error) {
result := &api.Namespace{} result = &api.Namespace{}
err := c.client.Put().Resource("namespaces").Name(namespace.Name).SubResource("status").Body(namespace).Do().Into(result) err = c.client.Put().
return result, err Resource("namespaces").
Name(namespace.Name).
SubResource("status").
Body(namespace).
Do().
Into(result)
return
} }
// Delete takes name of the namespace and deletes it. Returns an error if one occurs. // Delete takes name of the namespace and deletes it. Returns an error if one occurs.

View File

@ -75,10 +75,16 @@ func (c *nodes) Update(node *api.Node) (result *api.Node, err error) {
return return
} }
func (c *nodes) UpdateStatus(node *api.Node) (*api.Node, error) { func (c *nodes) UpdateStatus(node *api.Node) (result *api.Node, err error) {
result := &api.Node{} result = &api.Node{}
err := c.client.Put().Resource("nodes").Name(node.Name).SubResource("status").Body(node).Do().Into(result) err = c.client.Put().
return result, err Resource("nodes").
Name(node.Name).
SubResource("status").
Body(node).
Do().
Into(result)
return
} }
// Delete takes name of the node and deletes it. Returns an error if one occurs. // Delete takes name of the node and deletes it. Returns an error if one occurs.

View File

@ -75,10 +75,16 @@ func (c *persistentVolumes) Update(persistentVolume *api.PersistentVolume) (resu
return return
} }
func (c *persistentVolumes) UpdateStatus(persistentVolume *api.PersistentVolume) (*api.PersistentVolume, error) { func (c *persistentVolumes) UpdateStatus(persistentVolume *api.PersistentVolume) (result *api.PersistentVolume, err error) {
result := &api.PersistentVolume{} result = &api.PersistentVolume{}
err := c.client.Put().Resource("persistentVolumes").Name(persistentVolume.Name).SubResource("status").Body(persistentVolume).Do().Into(result) err = c.client.Put().
return result, err Resource("persistentVolumes").
Name(persistentVolume.Name).
SubResource("status").
Body(persistentVolume).
Do().
Into(result)
return
} }
// Delete takes name of the persistentVolume and deletes it. Returns an error if one occurs. // Delete takes name of the persistentVolume and deletes it. Returns an error if one occurs.

View File

@ -79,10 +79,17 @@ func (c *persistentVolumeClaims) Update(persistentVolumeClaim *api.PersistentVol
return return
} }
func (c *persistentVolumeClaims) UpdateStatus(persistentVolumeClaim *api.PersistentVolumeClaim) (*api.PersistentVolumeClaim, error) { func (c *persistentVolumeClaims) UpdateStatus(persistentVolumeClaim *api.PersistentVolumeClaim) (result *api.PersistentVolumeClaim, err error) {
result := &api.PersistentVolumeClaim{} result = &api.PersistentVolumeClaim{}
err := c.client.Put().Resource("persistentVolumeClaims").Name(persistentVolumeClaim.Name).SubResource("status").Body(persistentVolumeClaim).Do().Into(result) err = c.client.Put().
return result, err Namespace(c.ns).
Resource("persistentVolumeClaims").
Name(persistentVolumeClaim.Name).
SubResource("status").
Body(persistentVolumeClaim).
Do().
Into(result)
return
} }
// Delete takes name of the persistentVolumeClaim and deletes it. Returns an error if one occurs. // Delete takes name of the persistentVolumeClaim and deletes it. Returns an error if one occurs.

View File

@ -79,10 +79,17 @@ func (c *pods) Update(pod *api.Pod) (result *api.Pod, err error) {
return return
} }
func (c *pods) UpdateStatus(pod *api.Pod) (*api.Pod, error) { func (c *pods) UpdateStatus(pod *api.Pod) (result *api.Pod, err error) {
result := &api.Pod{} result = &api.Pod{}
err := c.client.Put().Resource("pods").Name(pod.Name).SubResource("status").Body(pod).Do().Into(result) err = c.client.Put().
return result, err Namespace(c.ns).
Resource("pods").
Name(pod.Name).
SubResource("status").
Body(pod).
Do().
Into(result)
return
} }
// Delete takes name of the pod and deletes it. Returns an error if one occurs. // Delete takes name of the pod and deletes it. Returns an error if one occurs.

View File

@ -79,10 +79,17 @@ func (c *replicationControllers) Update(replicationController *api.ReplicationCo
return return
} }
func (c *replicationControllers) UpdateStatus(replicationController *api.ReplicationController) (*api.ReplicationController, error) { func (c *replicationControllers) UpdateStatus(replicationController *api.ReplicationController) (result *api.ReplicationController, err error) {
result := &api.ReplicationController{} result = &api.ReplicationController{}
err := c.client.Put().Resource("replicationControllers").Name(replicationController.Name).SubResource("status").Body(replicationController).Do().Into(result) err = c.client.Put().
return result, err Namespace(c.ns).
Resource("replicationControllers").
Name(replicationController.Name).
SubResource("status").
Body(replicationController).
Do().
Into(result)
return
} }
// Delete takes name of the replicationController and deletes it. Returns an error if one occurs. // Delete takes name of the replicationController and deletes it. Returns an error if one occurs.

View File

@ -79,10 +79,17 @@ func (c *resourceQuotas) Update(resourceQuota *api.ResourceQuota) (result *api.R
return return
} }
func (c *resourceQuotas) UpdateStatus(resourceQuota *api.ResourceQuota) (*api.ResourceQuota, error) { func (c *resourceQuotas) UpdateStatus(resourceQuota *api.ResourceQuota) (result *api.ResourceQuota, err error) {
result := &api.ResourceQuota{} result = &api.ResourceQuota{}
err := c.client.Put().Resource("resourceQuotas").Name(resourceQuota.Name).SubResource("status").Body(resourceQuota).Do().Into(result) err = c.client.Put().
return result, err Namespace(c.ns).
Resource("resourceQuotas").
Name(resourceQuota.Name).
SubResource("status").
Body(resourceQuota).
Do().
Into(result)
return
} }
// Delete takes name of the resourceQuota and deletes it. Returns an error if one occurs. // Delete takes name of the resourceQuota and deletes it. Returns an error if one occurs.

View File

@ -79,10 +79,17 @@ func (c *services) Update(service *api.Service) (result *api.Service, err error)
return return
} }
func (c *services) UpdateStatus(service *api.Service) (*api.Service, error) { func (c *services) UpdateStatus(service *api.Service) (result *api.Service, err error) {
result := &api.Service{} result = &api.Service{}
err := c.client.Put().Resource("services").Name(service.Name).SubResource("status").Body(service).Do().Into(result) err = c.client.Put().
return result, err Namespace(c.ns).
Resource("services").
Name(service.Name).
SubResource("status").
Body(service).
Do().
Into(result)
return
} }
// Delete takes name of the service and deletes it. Returns an error if one occurs. // Delete takes name of the service and deletes it. Returns an error if one occurs.