summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorfisherxu <xufei40@huawei.com>2021-02-18 15:11:54 +0800
committerfisherxu <xufei40@huawei.com>2021-02-27 19:23:38 +0800
commitbc3f90d5a263fc691d5cffb26df19e3ce162bdc4 (patch)
tree763ae16d62220ba6b923129b1a07b4209870cf96
parentMerge pull request #2589 from fisherxu/automated-cherry-pick-of-#2587-upstrea... (diff)
downloadkubeedge-bc3f90d5a263fc691d5cffb26df19e3ce162bdc4.tar.gz
remove unused hardcode map
Signed-off-by: fisherxu <xufei40@huawei.com>
-rw-r--r--cloud/pkg/synccontroller/objectsync.go16
1 files changed, 2 insertions, 14 deletions
diff --git a/cloud/pkg/synccontroller/objectsync.go b/cloud/pkg/synccontroller/objectsync.go
index 5bf522db0..c29037734 100644
--- a/cloud/pkg/synccontroller/objectsync.go
+++ b/cloud/pkg/synccontroller/objectsync.go
@@ -23,15 +23,6 @@ import (
"github.com/kubeedge/kubeedge/pkg/metaserver/util"
)
-var forceSet = map[string]string{
- "pod": "pods",
- "configmap": "configmaps",
- "secret": "secrets",
- "service": "services",
- "endpoint": "endpoints",
- "node": "nodes",
-}
-
func (sctl *SyncController) manageObject(sync *v1alpha1.ObjectSync) {
var object metav1.Object
@@ -39,11 +30,8 @@ func (sctl *SyncController) manageObject(sync *v1alpha1.ObjectSync) {
if err != nil {
return
}
- resource := sync.Spec.ObjectKind // In fact, ObjdctKind is Object resources like "pods"
- if v, ok := forceSet[resource]; ok {
- resource = v
- }
- gvr := gv.WithResource(resource)
+ gvr := gv.WithResource(sync.Spec.ObjectKind)
+
//ret, err := informers.GetInformersManager().GetDynamicSharedInformerFactory().ForResource(gvr).Lister().ByNamespace(sync.Namespace).Get(sync.Spec.ObjectName)
ret, err := sctl.kubeclient.Resource(gvr).Namespace(sync.Namespace).Get(context.TODO(), sync.Spec.ObjectName, metav1.GetOptions{})
if err != nil {