add cluster and crd to resources api group (#2053)

pkg/apiserver/apiserver.go

@@ -406,6 +406,24 @@ func (s *APIServer) waitForResourceSync(stopCh <-chan struct{}) error {
 	snapshotInformerFactory.Start(stopCh)
 	snapshotInformerFactory.WaitForCacheSync(stopCh)
 
+	apiextensionsInformerFactory := s.InformerFactory.ApiExtensionSharedInformerFactory()
+	apiextensionsGVRs := []schema.GroupVersionResource{
+		{Group: "apiextensions.k8s.io", Version: "v1", Resource: "customresourcedefinitions"},
+	}
+
+	for _, gvr := range apiextensionsGVRs {
+		if !isResourceExists(gvr) {
+			klog.Warningf("resource %s not exists in the cluster", gvr)
+		} else {
+			_, err = apiextensionsInformerFactory.ForResource(gvr)
+			if err != nil {
+				return err
+			}
+		}
+	}
+	apiextensionsInformerFactory.Start(stopCh)
+	apiextensionsInformerFactory.WaitForCacheSync(stopCh)
+
 	klog.V(0).Info("Finished caching objects")
 
 	return nil

pkg/apiserver/authorization/authorizerfactory/opa_test.go

@@ -231,7 +231,7 @@ resources_in_cluster1 {
 
 	ksClient := fake.NewSimpleClientset()
 	k8sClient := fakek8s.NewSimpleClientset()
-	factory := factory.NewInformerFactories(k8sClient, ksClient, nil, nil, nil)
+	factory := factory.NewInformerFactories(k8sClient, ksClient, nil, nil, nil, nil)
 	for _, role := range globalRoles {
 		err := factory.KubeSphereSharedInformerFactory().Iam().V1alpha2().GlobalRoles().Informer().GetIndexer().Add(role)
 		if err != nil {

pkg/apiserver/authorization/authorizerfactory/rbac_test.go

@@ -243,7 +243,7 @@ func newMockRBACAuthorizer(staticRoles *StaticRoles) (*RBACAuthorizer, error) {
 	appClient := fakeapp.NewSimpleClientset()
 	snapshotClient := fakesnapshot.NewSimpleClientset()
 
-	fakeInformerFactory := informers.NewInformerFactories(k8sClient, ksClient, istioClient, appClient, snapshotClient)
+	fakeInformerFactory := informers.NewInformerFactories(k8sClient, ksClient, istioClient, appClient, snapshotClient, nil)
 
 	k8sInformerFactory := fakeInformerFactory.KubernetesSharedInformerFactory()