style: correct typos

Author: wu-cl

README.md

@@ -17,7 +17,7 @@ Everoute provides network and security services for the following platforms:
 * Hybrid Cloud
 * Legacy virtualized data center
 
-It can be intergated within these platforms easily.
+It can be integrated within these platforms easily.
 
 ## Architecture
 

pkg/agent/datapath/clsBridge.go

@@ -185,7 +185,7 @@ func (c *ClsBridge) initForwardingTable() error {
 	return nil
 }
 
-func (c *ClsBridge) initOuputTable(sw *ofctrl.OFSwitch) error {
+func (c *ClsBridge) initOutputTable(sw *ofctrl.OFSwitch) error {
 	localBrName := strings.TrimSuffix(c.name, "-cls")
 	// clsBridgeOutputTable floodingOutputFlow
 	floodingOutputFlow, _ := c.clsBridgeOutputTable.NewFlow(ofctrl.FlowMatch{
@@ -224,7 +224,7 @@ func (c *ClsBridge) initOuputTable(sw *ofctrl.OFSwitch) error {
 	}
 
 	// clsBridgeOutputTable learnedLocalToRemoteOuputFlow
-	learnedLocalToRemoteOuputFlow, _ := c.clsBridgeOutputTable.NewFlow(ofctrl.FlowMatch{
+	learnedLocalToRemoteOutputFlow, _ := c.clsBridgeOutputTable.NewFlow(ofctrl.FlowMatch{
 		Priority: NORMAL_MATCH_FLOW_PRIORITY,
 		Regs: []*ofctrl.NXRegister{
 			{
@@ -235,8 +235,8 @@ func (c *ClsBridge) initOuputTable(sw *ofctrl.OFSwitch) error {
 		},
 	})
 	outputPort, _ = sw.OutputPort(c.datapathManager.BridgeChainPortMap[localBrName][ClsToUplinkSuffix])
-	if err := learnedLocalToRemoteOuputFlow.Next(outputPort); err != nil {
-		return fmt.Errorf("failed to install cls bridge learnedLocalToRemoteOuputFlow, error: %v", err)
+	if err := learnedLocalToRemoteOutputFlow.Next(outputPort); err != nil {
+		return fmt.Errorf("failed to install cls bridge learnedLocalToRemoteOutputFlow, error: %v", err)
 	}
 
 	// clsBridgeOutputTable default flow
@@ -263,7 +263,7 @@ func (c *ClsBridge) BridgeInit() {
 	if err := c.initForwardingTable(); err != nil {
 		log.Fatalf("Failed to init cls bridge forwarding table, error: %v", err)
 	}
-	if err := c.initOuputTable(sw); err != nil {
+	if err := c.initOutputTable(sw); err != nil {
 		log.Fatalf("Failed to init cls bridge output table, error: %v", err)
 	}
 }

pkg/agent/datapath/policyBridge.go

@@ -389,7 +389,7 @@ func (p *PolicyBridge) initPolicyForwardingTable(sw *ofctrl.OFSwitch) error {
 		return fmt.Errorf("failed to install from local output flow, error: %v", err)
 	}
 
-	fromUpstreamOuputFlow, _ := p.policyForwardingTable.NewFlow(ofctrl.FlowMatch{
+	fromUpstreamOutputFlow, _ := p.policyForwardingTable.NewFlow(ofctrl.FlowMatch{
 		Priority:  NORMAL_MATCH_FLOW_PRIORITY,
 		InputPort: uint32(p.datapathManager.BridgeChainPortMap[localBrName][PolicyToClsSuffix]),
 		Regs: []*ofctrl.NXRegister{
@@ -401,7 +401,7 @@ func (p *PolicyBridge) initPolicyForwardingTable(sw *ofctrl.OFSwitch) error {
 		},
 	})
 	outputPort, _ = sw.OutputPort(p.datapathManager.BridgeChainPortMap[localBrName][PolicyToLocalSuffix])
-	if err := fromUpstreamOuputFlow.Next(outputPort); err != nil {
+	if err := fromUpstreamOutputFlow.Next(outputPort); err != nil {
 		return fmt.Errorf("failed to install from upstream output flow, error: %v", err)
 	}
 

tests/e2e/cases/security_test.go

@@ -1285,7 +1285,7 @@ func checkConnectionHealth(src, dst *model.Endpoint) <-chan ConnHealth {
 		// --- [dstIP] ping statistics ---
 		// [time] packets transmitted, [n1] packets received, [n2]% packet loss
 		output := regexp.MustCompile("\r\n|\n|\r").Split(fullOut, -1)
-		infoOutput := output[3] // expect: [n0] packets transmitted, [n1] packets recived, [n2]% packet loss
+		infoOutput := output[3] // expect: [n0] packets transmitted, [n1] packets received, [n2]% packet loss
 		connInfo := regexp.MustCompile("[0-9]+").FindAllString(infoOutput, -1)
 		klog.Info("Total,Received,Loss Rate,Time:", connInfo)
 		lossRate, err := strconv.Atoi(connInfo[2])

tests/e2e/framework/node/node.go

@@ -62,7 +62,7 @@ const (
 	RoleAgent      = "agent"
 )
 
-// GetClient return client connect to this node, must not close the returnd client.
+// GetClient return client connect to this node, must not close the returned client.
 func (n *Node) GetClient() (*ssh.Client, error) {
 	n.lock.Lock()
 	defer n.lock.Unlock()