diff options
| author | KubeEdge Bot <48982446+kubeedge-bot@users.noreply.github.com> | 2021-02-27 20:16:27 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-02-27 20:16:27 +0800 |
| commit | 497b04a346f828b8e73601e6b0fc947f4184aed3 (patch) | |
| tree | 763ae16d62220ba6b923129b1a07b4209870cf96 | |
| parent | Merge pull request #2589 from fisherxu/automated-cherry-pick-of-#2587-upstrea... (diff) | |
| parent | remove unused hardcode map (diff) | |
| download | kubeedge-1.6.0.tar.gz | |
Merge pull request #2590 from fisherxu/automated-cherry-pick-of-#2572-upstream-release-1.6v1.6.0
Automated cherry pick of #2572: remove unused hardcode map
| -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 { |