diff options
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) |