diff options
| author | KubeEdge Bot <48982446+kubeedge-bot@users.noreply.github.com> | 2020-02-06 22:57:20 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-02-06 22:57:20 +0800 |
| commit | a29fb98e0db42d7a5fb9120c413c948175c2aceb (patch) | |
| tree | fd30873abde2d1bab826045087b612f28fa5b410 /cloud/pkg/cloudhub/handler/messagehandler.go | |
| parent | Merge pull request #1431 from kadisi/edgesite_dir (diff) | |
| parent | update - to . in objectSync name (diff) | |
| download | kubeedge-1.2.0-beta.0.tar.gz | |
Merge pull request #1385 from fisherxu/synccontrollerv1.2.0-beta.0
Add synccontroller for reliable message delivery
Diffstat (limited to 'cloud/pkg/cloudhub/handler/messagehandler.go')
| -rw-r--r-- | cloud/pkg/cloudhub/handler/messagehandler.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/cloud/pkg/cloudhub/handler/messagehandler.go b/cloud/pkg/cloudhub/handler/messagehandler.go index 1c88db171..d36d4a980 100644 --- a/cloud/pkg/cloudhub/handler/messagehandler.go +++ b/cloud/pkg/cloudhub/handler/messagehandler.go @@ -24,6 +24,7 @@ import ( deviceconst "github.com/kubeedge/kubeedge/cloud/pkg/devicecontroller/constants" edgeconst "github.com/kubeedge/kubeedge/cloud/pkg/edgecontroller/constants" edgemessagelayer "github.com/kubeedge/kubeedge/cloud/pkg/edgecontroller/messagelayer" + "github.com/kubeedge/kubeedge/cloud/pkg/synccontroller" "github.com/kubeedge/kubeedge/common/constants" "github.com/kubeedge/viaduct/pkg/conn" "github.com/kubeedge/viaduct/pkg/mux" @@ -460,7 +461,7 @@ func (mh *MessageHandle) saveSuccessPoint(msg *beehiveModel.Message, info *model return } - objectSyncName := strings.Join([]string{info.NodeID, resourceUID}, "-") + objectSyncName := synccontroller.BuildObjectSyncName(info.NodeID, resourceUID) if msg.GetOperation() == beehiveModel.DeleteOperation { nodeStore.Delete(msg) |