diff options
| author | fisherxu <xufei40@huawei.com> | 2021-02-18 15:11:54 +0800 |
|---|---|---|
| committer | fisherxu <xufei40@huawei.com> | 2021-02-27 19:23:38 +0800 |
| commit | bc3f90d5a263fc691d5cffb26df19e3ce162bdc4 (patch) | |
| tree | 763ae16d62220ba6b923129b1a07b4209870cf96 | |
| parent | Merge pull request #2589 from fisherxu/automated-cherry-pick-of-#2587-upstrea... (diff) | |
| download | kubeedge-bc3f90d5a263fc691d5cffb26df19e3ce162bdc4.tar.gz | |
remove unused hardcode map
Signed-off-by: fisherxu <xufei40@huawei.com>
| -rw-r--r-- | cloud/pkg/synccontroller/objectsync.go | 16 |
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 { |
