diff options
| author | fisherxu <xufei40@huawei.com> | 2020-02-13 10:58:59 +0800 |
|---|---|---|
| committer | Kevin Wang <kevinwzf0126@gmail.com> | 2020-02-21 17:33:56 +0800 |
| commit | 7694954636e110b8cbf765ebceb33eec0f53f3de (patch) | |
| tree | 5144ea12ab95f7fa88c1e86102afd7384fa35aa6 | |
| parent | Merge pull request #1459 from fisherxu/release-1.2 (diff) | |
| download | kubeedge-7694954636e110b8cbf765ebceb33eec0f53f3de.tar.gz | |
fix bug for create pod in synccontroller
| -rw-r--r-- | cloud/pkg/synccontroller/objectsync.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/cloud/pkg/synccontroller/objectsync.go b/cloud/pkg/synccontroller/objectsync.go index e73c37ff9..312e813e1 100644 --- a/cloud/pkg/synccontroller/objectsync.go +++ b/cloud/pkg/synccontroller/objectsync.go @@ -42,6 +42,7 @@ func (sctl *SyncController) manageConfigMap(sync *v1alpha1.ObjectSync) { sendEvents(err, nodeName, sync.Namespace, sync.Spec.ObjectName, model.ResourceTypeConfigmap, configmap.ResourceVersion, sync.Status.ObjectResourceVersion, configmap) } + func (sctl *SyncController) manageSecret(sync *v1alpha1.ObjectSync) { secret, err := sctl.secretLister.Secrets(sync.Namespace).Get(sync.Spec.ObjectName) @@ -113,7 +114,7 @@ func sendEvents(err error, nodeName, namespace, objectName, resourceType string, if CompareResourceVersion(objectResourceVersion, syncResourceVersion) > 0 { // trigger the update event klog.Infof("The resourceVersion: %s of %s in K8s is greater than in edgenode: %s, send the update event", objectResourceVersion, resourceType, syncResourceVersion) - msg := buildEdgeControllerMessage(nodeName, namespace, model.ResourceTypePod, objectName, model.UpdateOperation, obj) + msg := buildEdgeControllerMessage(nodeName, namespace, resourceType, objectName, model.UpdateOperation, obj) beehiveContext.Send(commonconst.DefaultContextSendModuleName, *msg) } } |