updating unstrcutured client to fix the tests.

Author: Shawn Hurley

pkg/cache/cache_test.go

@@ -521,7 +521,7 @@ var _ = Describe("Informer Cache", func() {
 				By("verifying the object is received on the channel")
 				Eventually(out).Should(Receive(Equal(pod)))
 				close(done)
-			})
+			}, 3)
 
 			It("should be able to index an object field then retrieve objects by that field", func() {
 				By("creating the cache")
@@ -571,7 +571,7 @@ var _ = Describe("Informer Cache", func() {
 				Expect(listObj.Items).Should(HaveLen(1))
 				actual := listObj.Items[0]
 				Expect(actual.GetName()).To(Equal("test-pod-3"))
-			})
+			}, 3)
 		})
 	})
 })

pkg/client/unstructured_client.go

@@ -41,12 +41,16 @@ func (uc *unstructuredClient) Create(ctx context.Context, obj runtime.Object) er
 	if !ok {
 		return fmt.Errorf("unstructured client did not understand object: %T", obj)
 	}
-	r, err := uc.getResourceInterface(u.GroupVersionKind(), u.GetName())
+	r, err := uc.getResourceInterface(u.GroupVersionKind(), u.GetNamespace())
 	if err != nil {
 		return err
 	}
-	_, err = r.Create(u)
-	return err
+	i, err := r.Create(u)
+	if err != nil {
+		return err
+	}
+	u.Object = i.Object
+	return nil
 }
 
 // Update implements client.Client
@@ -55,12 +59,16 @@ func (uc *unstructuredClient) Update(ctx context.Context, obj runtime.Object) er
 	if !ok {
 		return fmt.Errorf("unstructured client did not understand object: %T", obj)
 	}
-	r, err := uc.getResourceInterface(u.GroupVersionKind(), u.GetName())
+	r, err := uc.getResourceInterface(u.GroupVersionKind(), u.GetNamespace())
 	if err != nil {
 		return err
 	}
-	u, err = r.Update(u)
-	return err
+	i, err := r.Update(u)
+	if err != nil {
+		return err
+	}
+	u.Object = i.Object
+	return nil
 }
 
 // Delete implements client.Client
@@ -69,7 +77,7 @@ func (uc *unstructuredClient) Delete(ctx context.Context, obj runtime.Object) er
 	if !ok {
 		return fmt.Errorf("unstructured client did not understand object: %T", obj)
 	}
-	r, err := uc.getResourceInterface(u.GroupVersionKind(), u.GetName())
+	r, err := uc.getResourceInterface(u.GroupVersionKind(), u.GetNamespace())
 	if err != nil {
 		return err
 	}
@@ -87,8 +95,12 @@ func (uc *unstructuredClient) Get(ctx context.Context, key ObjectKey, obj runtim
 	if err != nil {
 		return err
 	}
-	u, err = r.Get(key.Name, metav1.GetOptions{})
-	return err
+	i, err := r.Get(key.Name, metav1.GetOptions{})
+	if err != nil {
+		return err
+	}
+	u.Object = i.Object
+	return nil
 }
 
 // List implements client.Client
@@ -102,8 +114,12 @@ func (uc *unstructuredClient) List(ctx context.Context, opts *ListOptions, obj r
 	if err != nil {
 		return err
 	}
-	u, err = r.List(*opts.AsListOptions())
-	return err
+	i, err := r.List(*opts.AsListOptions())
+	if err != nil {
+		return err
+	}
+	u.Object = i.Object
+	return nil
 }
 
 func (uc *unstructuredClient) getResourceInterface(gvk schema.GroupVersionKind, ns string) (dynamic.ResourceInterface, error) {