fix querying local empty list error

cmd/yurthub/app/config/config.go

@@ -25,6 +25,7 @@ import (
 	"github.com/openyurtio/openyurt/cmd/yurthub/app/options"
 	"github.com/openyurtio/openyurt/pkg/projectinfo"
 	"github.com/openyurtio/openyurt/pkg/yurthub/cachemanager"
+	"github.com/openyurtio/openyurt/pkg/yurthub/kubernetes/meta"
 	"github.com/openyurtio/openyurt/pkg/yurthub/kubernetes/serializer"
 	"github.com/openyurtio/openyurt/pkg/yurthub/storage/factory"
 
@@ -53,6 +54,7 @@ type YurtHubConfiguration struct {
 	HubAgentDummyIfName         string
 	StorageWrapper              cachemanager.StorageWrapper
 	SerializerManager           *serializer.SerializerManager
+	RESTMapperManager           *meta.RESTMapperManager
 }
 
 // Complete converts *options.YurtHubOptions to *YurtHubConfiguration
@@ -69,6 +71,7 @@ func Complete(options *options.YurtHubOptions) (*YurtHubConfiguration, error) {
 	}
 	storageWrapper := cachemanager.NewStorageWrapper(storageManager)
 	serializerManager := serializer.NewSerializerManager()
+	restMapperManager := meta.NewRESTMapperManager(options.DiskCachePath)
 
 	hubServerAddr := net.JoinHostPort(options.YurtHubHost, options.YurtHubPort)
 	proxyServerAddr := net.JoinHostPort(options.YurtHubHost, options.YurtHubProxyPort)
@@ -94,6 +97,7 @@ func Complete(options *options.YurtHubOptions) (*YurtHubConfiguration, error) {
 		HubAgentDummyIfName:         options.HubAgentDummyIfName,
 		StorageWrapper:              storageWrapper,
 		SerializerManager:           serializerManager,
+		RESTMapperManager:           restMapperManager,
 	}
 
 	return cfg, nil

cmd/yurthub/app/start.go

@@ -111,7 +111,7 @@ func Run(cfg *config.YurtHubConfiguration, stopCh <-chan struct{}) error {
 	trace++
 
 	klog.Infof("%d. new cache manager with storage wrapper and serializer manager", trace)
-	cacheMgr, err := cachemanager.NewCacheManager(cfg.StorageWrapper, cfg.SerializerManager)
+	cacheMgr, err := cachemanager.NewCacheManager(cfg.StorageWrapper, cfg.SerializerManager, cfg.RESTMapperManager)
 	if err != nil {
 		klog.Errorf("could not new cache manager, %v", err)
 		return err
@@ -128,7 +128,7 @@ func Run(cfg *config.YurtHubConfiguration, stopCh <-chan struct{}) error {
 	trace++
 
 	klog.Infof("%d. new reverse proxy handler for remote servers", trace)
-	yurtProxyHandler, err := proxy.NewYurtReverseProxyHandler(cfg, cacheMgr, transportManager, healthChecker, certManager, stopCh)
+	yurtProxyHandler, err := proxy.NewYurtReverseProxyHandler(cfg, cacheMgr, transportManager, healthChecker, certManager, cfg.RESTMapperManager, stopCh)
 	if err != nil {
 		klog.Errorf("could not create reverse proxy handler, %v", err)
 		return err

pkg/yurthub/cachemanager/cache_agent_test.go

@@ -32,7 +32,7 @@ func TestInitCacheAgents(t *testing.T) {
 		t.Errorf("failed to create disk storage, %v", err)
 	}
 	s := NewStorageWrapper(dStorage)
-	m, _ := NewCacheManager(s, nil)
+	m, _ := NewCacheManager(s, nil, nil)
 
 	// default cache agents in fake store
 	b, err := s.GetRaw(cacheAgentsKey)
@@ -52,7 +52,7 @@ func TestInitCacheAgents(t *testing.T) {
 	// add agents for next init cache
 	_ = m.UpdateCacheAgents([]string{"agent1"})
 
-	_, _ = NewCacheManager(s, nil)
+	_, _ = NewCacheManager(s, nil, nil)
 
 	b2, err := s.GetRaw(cacheAgentsKey)
 	if err != nil {
@@ -81,7 +81,7 @@ func TestUpdateCacheAgents(t *testing.T) {
 		t.Errorf("failed to create disk storage, %v", err)
 	}
 	s := NewStorageWrapper(dStorage)
-	m, _ := NewCacheManager(s, nil)
+	m, _ := NewCacheManager(s, nil, nil)
 
 	testcases := map[string]struct {
 		desc         string

pkg/yurthub/cachemanager/cache_manager.go

@@ -28,6 +28,7 @@ import (
 	"strings"
 	"sync"
 
+	meta2 "github.com/openyurtio/openyurt/pkg/yurthub/kubernetes/meta"
 	"github.com/openyurtio/openyurt/pkg/yurthub/kubernetes/serializer"
 	"github.com/openyurtio/openyurt/pkg/yurthub/storage"
 	"github.com/openyurtio/openyurt/pkg/yurthub/util"
@@ -58,6 +59,7 @@ type cacheManager struct {
 	sync.RWMutex
 	storage               StorageWrapper
 	serializerManager     *serializer.SerializerManager
+	restMapperManager     *meta2.RESTMapperManager
 	cacheAgents           map[string]bool
 	listSelectorCollector map[string]string
 }
@@ -66,10 +68,12 @@ type cacheManager struct {
 func NewCacheManager(
 	storage StorageWrapper,
 	serializerMgr *serializer.SerializerManager,
+	restMapperMgr *meta2.RESTMapperManager,
 ) (CacheManager, error) {
 	cm := &cacheManager{
 		storage:               storage,
 		serializerManager:     serializerMgr,
+		restMapperManager:     restMapperMgr,
 		cacheAgents:           make(map[string]bool),
 		listSelectorCollector: make(map[string]string),
 	}
@@ -152,13 +156,14 @@ func (cm *cacheManager) queryListObject(req *http.Request) (runtime.Object, erro
 	if err != nil {
 		return nil, err
 	} else if len(objs) == 0 {
-		gvk, err = serializer.UnsafeDefaultRESTMapper.KindFor(schema.GroupVersionResource{
+		gvr := schema.GroupVersionResource{
 			Group:    info.APIGroup,
 			Version:  info.APIVersion,
 			Resource: info.Resource,
-		})
-		if err != nil {
-			return nil, err
+		}
+		_, gvk = cm.restMapperManager.KindFor(gvr)
+		if gvk.Empty() {
+			return nil, fmt.Errorf("no matches for %v", gvr)
 		}
 		kind = gvk.Kind
 	} else {
@@ -349,6 +354,11 @@ func (cm *cacheManager) saveListObject(ctx context.Context, info *apirequest.Req
 	}.String()
 	accessor := meta.NewAccessor()
 
+	// Verify if DynamicRESTMapper(which store the CRD info) needs to be updated
+	if err := cm.restMapperManager.UpdateKind(schema.GroupVersionKind{Group: info.APIGroup, Version: info.APIVersion, Kind: kind}); err != nil {
+		klog.Errorf("failed to update the DynamicRESTMapper %v", err)
+	}
+
 	comp, _ := util.ClientComponentFrom(ctx)
 	// even if no objects in cloud cluster, we need to
 	// make up a storage that represents the no resources
@@ -437,6 +447,12 @@ func (cm *cacheManager) saveOneObject(ctx context.Context, info *apirequest.Requ
 		return err
 	}
 
+	// Verify if DynamicRESTMapper(which store the CRD info) needs to be updated
+	gvk := obj.GetObjectKind().GroupVersionKind()
+	if err := cm.restMapperManager.UpdateKind(gvk); err != nil {
+		klog.Errorf("failed to update the DynamicRESTMapper %v", err)
+	}
+
 	if err := cm.saveOneObjectWithValidation(key, obj); err != nil {
 		if err != storage.ErrStorageAccessConflict {
 			return err