Avoid contacting kube apiserver is patch is empty

Signed-off-by: Tamal Saha <[email protected]>

Author: tamalsaha

pkg/client/metadata_client.go

@@ -98,14 +98,14 @@ func (mc *metadataClient) Patch(ctx context.Context, obj Object, patch Patch, op
 		return err
 	}
 
+	patchOpts := &PatchOptions{}
+	patchOpts.ApplyOptions(opts)
+
 	data, err := patch.Data(obj)
-	if err != nil {
+	if err != nil || (!patchOpts.SendEmptyPatch && string(data) == "{}") {
 		return err
 	}
 
-	patchOpts := &PatchOptions{}
-	patchOpts.ApplyOptions(opts)
-
 	res, err := resInt.Patch(ctx, metadata.Name, patch.Type(), data, *patchOpts.AsPatchOptions())
 	if err != nil {
 		return err
@@ -189,7 +189,7 @@ func (mc *metadataClient) PatchSubResource(ctx context.Context, obj Object, subR
 	}
 
 	data, err := patch.Data(body)
-	if err != nil {
+	if err != nil || (!patchOpts.SendEmptyPatch && string(data) == "{}") {
 		return err
 	}
 

pkg/client/options.go

@@ -842,6 +842,9 @@ type PatchOptions struct {
 
 	// Raw represents raw PatchOptions, as passed to the API server.
 	Raw *metav1.PatchOptions
+
+	// SendEmptyPatch is going to send empty patch calls to the API server.
+	SendEmptyPatch bool
 }
 
 // ApplyOptions applies the given patch options on these options,
@@ -908,6 +911,16 @@ func (forceOwnership) ApplyToSubResourcePatch(opts *SubResourcePatchOptions) {
 	opts.Force = &definitelyTrue
 }
 
+// SendEmptyPatch sets the "sendEmptyPatch" option to true.
+var SendEmptyPatch = sendEmptyPatch{}
+
+type sendEmptyPatch struct{}
+
+// ApplyToPatch applies this configuration to the given patch options.
+func (sendEmptyPatch) ApplyToPatch(opts *PatchOptions) {
+	opts.SendEmptyPatch = true
+}
+
 // }}}
 
 // {{{ DeleteAllOf Options

pkg/client/typed_client.go

@@ -114,14 +114,14 @@ func (c *typedClient) Patch(ctx context.Context, obj Object, patch Patch, opts .
 		return err
 	}
 
+	patchOpts := &PatchOptions{}
+	patchOpts.ApplyOptions(opts)
+
 	data, err := patch.Data(obj)
-	if err != nil {
+	if err != nil || (!patchOpts.SendEmptyPatch && string(data) == "{}") {
 		return err
 	}
 
-	patchOpts := &PatchOptions{}
-	patchOpts.ApplyOptions(opts)
-
 	return o.Patch(patch.Type()).
 		NamespaceIfScoped(o.GetNamespace(), o.isNamespaced()).
 		Resource(o.resource()).
@@ -263,7 +263,7 @@ func (c *typedClient) PatchSubResource(ctx context.Context, obj Object, subResou
 	}
 
 	data, err := patch.Data(body)
-	if err != nil {
+	if err != nil || (!patchOpts.SendEmptyPatch && string(data) == "{}") {
 		return err
 	}
 

pkg/client/unstructured_client.go

@@ -148,14 +148,14 @@ func (uc *unstructuredClient) Patch(ctx context.Context, obj Object, patch Patch
 		return err
 	}
 
+	patchOpts := &PatchOptions{}
+	patchOpts.ApplyOptions(opts)
+
 	data, err := patch.Data(obj)
-	if err != nil {
+	if err != nil || (!patchOpts.SendEmptyPatch && string(data) == "{}") {
 		return err
 	}
 
-	patchOpts := &PatchOptions{}
-	patchOpts.ApplyOptions(opts)
-
 	return o.Patch(patch.Type()).
 		NamespaceIfScoped(o.GetNamespace(), o.isNamespaced()).
 		Resource(o.resource()).
@@ -342,7 +342,7 @@ func (uc *unstructuredClient) PatchSubResource(ctx context.Context, obj Object,
 	}
 
 	data, err := patch.Data(body)
-	if err != nil {
+	if err != nil || (!patchOpts.SendEmptyPatch && string(data) == "{}") {
 		return err
 	}