diff options
| author | yojay11717 <lanyujie@inspur.com> | 2022-06-22 15:24:13 +0800 |
|---|---|---|
| committer | yojay11717 <lanyujie@inspur.com> | 2022-06-22 15:30:28 +0800 |
| commit | 43c301a21da3d0c0df2048868a97298a5eca0470 (patch) | |
| tree | aa2e5660ca7c59944dd924efe552c92c1f3c1d86 /tests | |
| parent | Merge pull request #3945 from xuxiawei/cleanup/util (diff) | |
| download | kubeedge-43c301a21da3d0c0df2048868a97298a5eca0470.tar.gz | |
fix typos
Signed-off-by: yojay11717 <lanyujie@inspur.com>
Diffstat (limited to 'tests')
| -rw-r--r-- | tests/e2e/deployment/rule_crd_test.go | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/tests/e2e/deployment/rule_crd_test.go b/tests/e2e/deployment/rule_crd_test.go index 7643f1269..8eb11eaf8 100644 --- a/tests/e2e/deployment/rule_crd_test.go +++ b/tests/e2e/deployment/rule_crd_test.go @@ -91,11 +91,11 @@ var _ = Describe("Rule Management test in E2E scenario", func() { Expect(err).To(BeNil()) b := new(bytes.Buffer) go func() { - recieveMsg, err := utils.SubscribeMqtt("topic-test") + receiveMsg, err := utils.SubscribeMqtt("topic-test") if err != nil { utils.Fatalf("subscribe topic-test fail. reason: %s. ", err.Error()) } - b.WriteString(recieveMsg) + b.WriteString(receiveMsg) }() time.Sleep(3 * time.Second) // call rest api to send message to edge. @@ -121,11 +121,11 @@ var _ = Describe("Rule Management test in E2E scenario", func() { Expect(statusCode).Should(Equal(http.StatusCreated)) b := new(bytes.Buffer) go func() { - recieveMsg, err := utils.StartEchoServer() + receiveMsg, err := utils.StartEchoServer() if err != nil { utils.Fatalf("subscribe topic-test fail. reason: %s. ", err.Error()) } - b.WriteString(recieveMsg) + b.WriteString(receiveMsg) }() time.Sleep(3 * time.Second) // call rest api to send message to edge. @@ -158,11 +158,11 @@ var _ = Describe("Rule Management test in E2E scenario", func() { } b := new(bytes.Buffer) go func() { - recieveMsg, err := utils.StartEchoServer() + receiveMsg, err := utils.StartEchoServer() if err != nil { utils.Fatalf("fail to call edge-app's API. reason: %s. ", err.Error()) } - b.WriteString(recieveMsg) + b.WriteString(receiveMsg) }() time.Sleep(3 * time.Second) // call rest api to send message to edge. @@ -192,11 +192,11 @@ var _ = Describe("Rule Management test in E2E scenario", func() { Expect(statusCode).Should(Equal(http.StatusCreated)) b := new(bytes.Buffer) go func() { - recieveMsg, err := utils.StartEchoServer() + receiveMsg, err := utils.StartEchoServer() if err != nil { utils.Fatalf("fail to call cloud-app's API. reason: %s. ", err.Error()) } - b.WriteString(recieveMsg) + b.WriteString(receiveMsg) }() time.Sleep(3 * time.Second) resp, err := utils.CallServicebus() |