WIP: client: update status subresource support

Author: droot

pkg/client/client.go

@@ -110,6 +110,24 @@ func (c *client) Update(ctx context.Context, obj runtime.Object) error {
 		Into(obj)
 }
 
+// UpdateStatus implements client.Client
+func (c *client) UpdateStatus(ctx context.Context, obj runtime.Object) error {
+	o, err := c.cache.getObjMeta(obj)
+	if err != nil {
+		return err
+	}
+	// TODO(droot): examine the returned error and check if it error needs to be
+	// wrapped to improve the UX ?
+	return o.Put().
+		NamespaceIfScoped(o.GetNamespace(), o.isNamespaced()).
+		Resource(o.resource()).
+		Name(o.GetName()).
+		SubResource("status").
+		Body(obj).
+		Do().
+		Into(obj)
+}
+
 // Delete implements client.Client
 func (c *client) Delete(ctx context.Context, obj runtime.Object) error {
 	o, err := c.cache.getObjMeta(obj)

pkg/client/fake/client.go

@@ -123,6 +123,11 @@ func (c *fakeClient) Update(ctx context.Context, obj runtime.Object) error {
 	return c.tracker.Update(gvr, obj, accessor.GetNamespace())
 }
 
+func (c *fakeClient) UpdateStatus(ctx context.Context, obj runtime.Object) error {
+	// TODO(droot): implement for *real*
+	return nil
+}
+
 func getGVRFromObject(obj runtime.Object) (schema.GroupVersionResource, error) {
 	gvk, err := apiutil.GVKForObject(obj, scheme.Scheme)
 	if err != nil {

pkg/client/interfaces.go

@@ -55,6 +55,11 @@ type Writer interface {
 	// Update updates the given obj in the Kubernetes cluster. obj must be a
 	// struct pointer so that obj can be updated with the content returned by the Server.
 	Update(ctx context.Context, obj runtime.Object) error
+
+	// UpdateStatus updates the fields corresponding to status subresource for
+	// the given obj. obj must be a struct pointer so that obj can be updated
+	// with the content returned by the Server.
+	UpdateStatus(ctx context.Context, obj runtime.Object) error
 }
 
 // Client knows how to perform CRUD operations on Kubernetes objects.