diff options
| author | gy95 <guoyao17@huawei.com> | 2022-04-22 17:00:37 +0800 |
|---|---|---|
| committer | gy95 <guoyao17@huawei.com> | 2022-09-22 14:44:06 +0800 |
| commit | d887c7c416f3f38ec4b69241229289fe62ba1bbf (patch) | |
| tree | e61fa01a5144b524861a99ed5d3dae500541e221 /tests | |
| parent | Merge pull request #4125 from wackxu/fixdeletetermin (diff) | |
| download | kubeedge-d887c7c416f3f38ec4b69241229289fe62ba1bbf.tar.gz | |
support operations: upgrade edge node from cloud
Signed-off-by: gy95 <guoyao17@huawei.com>
Diffstat (limited to 'tests')
| -rw-r--r-- | tests/e2e/utils/node.go | 4 |
1 files changed, 3 insertions, 1 deletions
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) |