Merge pull request #435 from DirectXMan12/feature/minimal-apply

⚠️ Minimal Apply Support, Fix Up Client Options

Author: k8s-ci-robot

pkg/client/client.go

@@ -171,10 +171,19 @@ type statusWriter struct {
 var _ StatusWriter = &statusWriter{}
 
 // Update implements client.StatusWriter
-func (sw *statusWriter) Update(ctx context.Context, obj runtime.Object) error {
+func (sw *statusWriter) Update(ctx context.Context, obj runtime.Object, opts ...UpdateOptionFunc) error {
 _, ok := obj.(*unstructured.Unstructured)
 if ok {
-return sw.client.unstructuredClient.UpdateStatus(ctx, obj)
+return sw.client.unstructuredClient.UpdateStatus(ctx, obj, opts...)
 }
-return sw.client.typedClient.UpdateStatus(ctx, obj)
+return sw.client.typedClient.UpdateStatus(ctx, obj, opts...)
+}
+
+// Patch implements client.Client
+func (sw *statusWriter) Patch(ctx context.Context, obj runtime.Object, patch Patch, opts ...PatchOptionFunc) error {
+_, ok := obj.(*unstructured.Unstructured)
+if ok {
+return sw.client.unstructuredClient.PatchStatus(ctx, obj, patch, opts...)
+}
+return sw.client.typedClient.PatchStatus(ctx, obj, patch, opts...)
 }

pkg/client/client_test.go

@@ -276,7 +276,7 @@ var _ = Describe("Client", func() {
 Expect(cl).NotTo(BeNil())
 
 By("creating the object (with DryRun)")
-err = cl.Create(context.TODO(), dep, client.CreateDryRunAll())
+err = cl.Create(context.TODO(), dep, client.CreateDryRunAll)
 Expect(err).NotTo(HaveOccurred())
 
 actual, err := clientset.AppsV1().Deployments(ns).Get(dep.Name, metav1.GetOptions{})
@@ -415,7 +415,7 @@ var _ = Describe("Client", func() {
 })
 
 By("creating the object")
-err = cl.Create(context.TODO(), u, client.CreateDryRunAll())
+err = cl.Create(context.TODO(), u, client.CreateDryRunAll)
 Expect(err).NotTo(HaveOccurred())
 
 actual, err := clientset.AppsV1().Deployments(ns).Get(dep.Name, metav1.GetOptions{})
@@ -1074,7 +1074,7 @@ var _ = Describe("Client", func() {
 Expect(err).NotTo(HaveOccurred())
 
 By("patching the Deployment with dry-run")
-err = cl.Patch(context.TODO(), dep, client.ConstantPatch(types.MergePatchType, mergePatch), client.PatchDryRunAll())
+err = cl.Patch(context.TODO(), dep, client.ConstantPatch(types.MergePatchType, mergePatch), client.PatchDryRunAll)
 Expect(err).NotTo(HaveOccurred())
 
 By("validating patched Deployment doesn't have the new annotation")
@@ -1183,7 +1183,7 @@ var _ = Describe("Client", func() {
 Kind: "Deployment",
 Version: "v1",
 })
-err = cl.Patch(context.TODO(), u, client.ConstantPatch(types.MergePatchType, mergePatch), client.PatchDryRunAll())
+err = cl.Patch(context.TODO(), u, client.ConstantPatch(types.MergePatchType, mergePatch), client.PatchDryRunAll)
 Expect(err).NotTo(HaveOccurred())
 
 By("validating patched Deployment does not have the new annotation")
@@ -2000,7 +2000,7 @@ var _ = Describe("Client", func() {
 Describe("CreateOptions", func() {
 It("should allow setting DryRun to 'all'", func() {
 co := &client.CreateOptions{}
-client.CreateDryRunAll()(co)
+client.CreateDryRunAll(co)
 all := []string{metav1.DryRunAll}
 Expect(co.AsCreateOptions().DryRun).To(Equal(all))
 })
@@ -2141,7 +2141,7 @@ var _ = Describe("Client", func() {
 Describe("UpdateOptions", func() {
 It("should allow setting DryRun to 'all'", func() {
 uo := &client.UpdateOptions{}
-client.UpdateDryRunAll()(uo)
+client.UpdateDryRunAll(uo)
 all := []string{metav1.DryRunAll}
 Expect(uo.AsUpdateOptions().DryRun).To(Equal(all))
 })
@@ -2157,19 +2157,25 @@ var _ = Describe("Client", func() {
 Describe("PatchOptions", func() {
 It("should allow setting DryRun to 'all'", func() {
 po := &client.PatchOptions{}
-client.PatchDryRunAll()(po)
+client.PatchDryRunAll(po)
 all := []string{metav1.DryRunAll}
 Expect(po.AsPatchOptions().DryRun).To(Equal(all))
 })
 
 It("should allow setting Force to 'true'", func() {
 po := &client.PatchOptions{}
-client.PatchWithForce()(po)
+client.ForceOwnership(po)
 mpo := po.AsPatchOptions()
 Expect(mpo.Force).NotTo(BeNil())
 Expect(*mpo.Force).To(BeTrue())
 })
 
+It("should allow setting the field manager", func() {
+po := &client.PatchOptions{}
+client.FieldOwner("some-owner")(po)
+Expect(po.AsPatchOptions().FieldManager).To(Equal("some-owner"))
+})
+
 It("should produce empty metav1.PatchOptions if nil", func() {
 var po *client.PatchOptions
 Expect(po.AsPatchOptions()).To(Equal(&metav1.PatchOptions{}))

pkg/client/fake/client.go

@@ -244,8 +244,14 @@ type fakeStatusWriter struct {
 client *fakeClient
 }
 
-func (sw *fakeStatusWriter) Update(ctx context.Context, obj runtime.Object) error {
+func (sw *fakeStatusWriter) Update(ctx context.Context, obj runtime.Object, opts ...client.UpdateOptionFunc) error {
 // TODO(droot): This results in full update of the obj (spec + status). Need
 // a way to update status field only.
-return sw.client.Update(ctx, obj)
+return sw.client.Update(ctx, obj, opts...)
+}
+
+func (sw *fakeStatusWriter) Patch(ctx context.Context, obj runtime.Object, patch client.Patch, opts ...client.PatchOptionFunc) error {
+// TODO(droot): This results in full update of the obj (spec + status). Need
+// a way to update status field only.
+return sw.client.Patch(ctx, obj, patch, opts...)
 }

pkg/client/fake/client_test.go

@@ -167,7 +167,7 @@ var _ = Describe("Fake client", func() {
 Namespace: "ns2",
 },
 }
-err := cl.Create(nil, newcm, client.CreateDryRunAll())
+err := cl.Create(nil, newcm, client.CreateDryRunAll)
 Expect(err).To(BeNil())
 
 By("Getting the new configmap")
@@ -193,7 +193,7 @@ var _ = Describe("Fake client", func() {
 "test-key": "new-value",
 },
 }
-err := cl.Update(nil, newcm, client.UpdateDryRunAll())
+err := cl.Update(nil, newcm, client.UpdateDryRunAll)
 Expect(err).To(BeNil())
 
 By("Getting the new configmap")