From d887c7c416f3f38ec4b69241229289fe62ba1bbf Mon Sep 17 00:00:00 2001 From: gy95 Date: Fri, 22 Apr 2022 17:00:37 +0800 Subject: support operations: upgrade edge node from cloud Signed-off-by: gy95 --- tests/e2e/utils/node.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) (limited to 'tests') diff --git a/tests/e2e/utils/node.go b/tests/e2e/utils/node.go index ab9795a29..a81b86c94 100644 --- a/tests/e2e/utils/node.go +++ b/tests/e2e/utils/node.go @@ -32,6 +32,8 @@ import ( "github.com/onsi/gomega" v1 "k8s.io/api/core/v1" "sigs.k8s.io/yaml" + + "github.com/kubeedge/kubeedge/common/constants" ) func getpwd() string { @@ -61,7 +63,7 @@ func DeRegisterNodeFromMaster(nodehandler, nodename string) error { func GenerateNodeReqBody(nodeid, nodeselector string) (map[string]interface{}, error) { var temp map[string]interface{} - body := fmt.Sprintf(`{"kind": "Node","apiVersion": "v1","metadata": {"name": "%s","labels": {"name": "edgenode", "disktype":"%s", "node-role.kubernetes.io/edge": ""}}}`, nodeid, nodeselector) + body := fmt.Sprintf(`{"kind": "Node","apiVersion": "v1","metadata": {"name": "%s","labels": {"name": "edgenode", "disktype":"%s", "%s": "%s"}}}`, nodeid, nodeselector, constants.EdgeNodeRoleKey, constants.EdgeNodeRoleValue) err := json.Unmarshal([]byte(body), &temp) if err != nil { Fatalf("Unmarshal body failed: %v", err) -- cgit v1.2.3