The resource rest mapper changed what the default operation is, and now we have to ask for the resource directly.

Author: Scott Nichols

pkg/cache/internal/informers_map.go

@@ -217,14 +217,14 @@ func (ip *InformersMap) newListWatch(gvk schema.GroupVersionKind) (*cache.ListWa
 	return &cache.ListWatch{
 		ListFunc: func(opts metav1.ListOptions) (runtime.Object, error) {
 			res := listObj.DeepCopyObject()
-			err := client.Get().Resource(mapping.Resource.String()).VersionedParams(&opts, ip.paramCodec).Do().Into(res)
+			err := client.Get().Resource(mapping.Resource.Resource).VersionedParams(&opts, ip.paramCodec).Do().Into(res)
 			return res, err
 		},
 		// Setup the watch function
 		WatchFunc: func(opts metav1.ListOptions) (watch.Interface, error) {
 			// Watch needs to be set to true separately
 			opts.Watch = true
-			return client.Get().Resource(mapping.Resource.String()).VersionedParams(&opts, ip.paramCodec).Watch()
+			return client.Get().Resource(mapping.Resource.Resource).VersionedParams(&opts, ip.paramCodec).Watch()
 		},
 	}, nil
 }

pkg/client/client_cache.go

@@ -132,7 +132,7 @@ func (r *resourceMeta) isNamespaced() bool {
 
 // resource returns the resource name of the type
 func (r *resourceMeta) resource() string {
-	return r.mapping.Resource.String()
+	return r.mapping.Resource.Resource
 }
 
 // objMeta stores type and object information about a Kubernetes type