Merge pull request kubeedge#5128 from testwill/typo

fix: typo
zhiyingfang2022 · Nov 3, 2023 · 36e0e06 · 36e0e06
2 parents 1fd5531 + 10af84b
commit 36e0e06
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/common/constants/default.go b/common/constants/default.go
@@ -150,7 +150,7 @@ const (
 	EdgeNodeRoleKey   = "node-role.kubernetes.io/edge"
 	EdgeNodeRoleValue = ""
 
-	DeafultMosquittoContainerName = "mqtt-kubeedge"
+	DefaultMosquittoContainerName = "mqtt-kubeedge"
 	DeployMqttContainerEnv        = "DEPLOY_MQTT_CONTAINER"
 
 	// DefaultManifestsDir edge node default static pod path

diff --git a/edge/pkg/metamanager/client/pod.go b/edge/pkg/metamanager/client/pod.go
@@ -110,7 +110,7 @@ func (c *pods) Get(name string) (*corev1.Pod, error) {
 
 func (c *pods) Patch(name string, patchBytes []byte) (*corev1.Pod, error) {
 	resource := fmt.Sprintf("%s/%s/%s", c.namespace, model.ResourceTypePodPatch, name)
-	if name == constants.DeafultMosquittoContainerName {
+	if name == constants.DefaultMosquittoContainerName {
 		return handleMqttMeta()
 	}
 	podMsg := message.BuildMsg(modules.MetaGroup, "", modules.EdgedModuleName, resource, model.PatchOperation, string(patchBytes))
@@ -191,7 +191,7 @@ func updatePodDB(resource string, pod *corev1.Pod) error {
 
 func handleMqttMeta() (*corev1.Pod, error) {
 	var pod corev1.Pod
-	metas, err := dao.QueryMeta("key", fmt.Sprintf("default/pod/%s", constants.DeafultMosquittoContainerName))
+	metas, err := dao.QueryMeta("key", fmt.Sprintf("default/pod/%s", constants.DefaultMosquittoContainerName))
 	if err != nil || len(*metas) != 1 {
 		return nil, fmt.Errorf("get mqtt meta failed, err: %v", err)
 	}

diff --git a/edge/pkg/metamanager/dao/meta.go b/edge/pkg/metamanager/dao/meta.go
@@ -128,7 +128,7 @@ func SaveMQTTMeta(nodeName string) error {
 			APIVersion: "v1",
 		},
 		ObjectMeta: metaV1.ObjectMeta{
-			Name:      constants.DeafultMosquittoContainerName,
+			Name:      constants.DefaultMosquittoContainerName,
 			Namespace: "default",
 			UID:       uuid.NewUUID(),
 		},
@@ -174,7 +174,7 @@ func SaveMQTTMeta(nodeName string) error {
 	}
 	mqttDataStr, _ := json.Marshal(mqttData)
 	mqttMeta := Meta{
-		Key:   fmt.Sprintf("default/pod/%s", constants.DeafultMosquittoContainerName),
+		Key:   fmt.Sprintf("default/pod/%s", constants.DefaultMosquittoContainerName),
 		Type:  "pod",
 		Value: string(mqttDataStr),
 	}