feat: update connection api and doc

docs/en_US/api/restapi/connection.md

@@ -19,6 +19,21 @@ POST http://localhost:9081/connections
 }
 ```
 
+### Update connection
+
+To update a connection, provide the connection's id, type, and configuration parameters. Currently, `mqtt`/`nng`/`httppush`/`websocket`/`edgex`/`sql` types of connections are supported. Here we take updating the mqtt connection as an example. If the connection is referenced by a rule, it cannot be updated.
+
+```shell
+PUT http://localhost:9081/connections/connection-1
+{
+  "id": "connecton-1",
+  "typ":"mqtt",
+  "props": {
+    "server": "tcp://127.0.0.1:1883"
+  }
+}
+```
+
 ### Get all connection information
 
 ```shell

docs/zh_CN/api/restapi/connection.md

@@ -19,6 +19,21 @@ POST http://localhost:9081/connections
 }
 ```
 
+### 更新连接
+
+更新连接要提供连接的 id, 类型和配置参数。目前已经支持了 `mqtt`/`nng`/`httppush`/`websocket`/`edgex`/`sql` 类型的连接，这里以更新 mqtt 连接为例。如果连接被规则引用中，则无法被更新。
+
+```shell
+PUT http://localhost:9081/connections/connection-1
+{
+  "id": "connecton-1",
+  "typ":"mqtt",
+  "props": {
+    "server": "tcp://127.0.0.1:1883"
+  }
+}
+```
+
 ### 获取所有连接信息
 
 ```shell

internal/server/connection.go

@@ -18,6 +18,7 @@ import (
 	"encoding/json"
 	"io"
 	"net/http"
+	"strconv"
 
 	"github.com/gorilla/mux"
 
@@ -53,7 +54,8 @@ func connectionsHandler(w http.ResponseWriter, r *http.Request) {
 		w.WriteHeader(http.StatusCreated)
 		w.Write([]byte("success"))
 	case http.MethodGet:
-		metaList := connection.GetAllConnectionsMeta()
+		forceAll, _ := strconv.ParseBool(r.URL.Query().Get("forceAll"))
+		metaList := connection.GetAllConnectionsMeta(forceAll)
 		resp := make([]*ConnectionResponse, 0)
 		for _, meta := range metaList {
 			resp = append(resp, getConnectionRespByMeta(meta))

internal/server/connection_test.go

@@ -46,7 +46,7 @@ func (suite *RestTestSuite) TestGetConnectionStatus() {
 	require.Equal(suite.T(), http.StatusCreated, w.Code)
 
 	time.Sleep(100 * time.Millisecond)
-	req, _ = http.NewRequest(http.MethodGet, "http://localhost:8080/connections", bytes.NewBufferString("any"))
+	req, _ = http.NewRequest(http.MethodGet, "http://localhost:8080/connections?forceAll=true", bytes.NewBufferString("any"))
 	w = httptest.NewRecorder()
 	suite.r.ServeHTTP(w, req)
 	require.Equal(suite.T(), http.StatusOK, w.Code)

pkg/connection/pool.go

@@ -167,11 +167,14 @@
 	return meta.cw, nil
 }
 
-func GetAllConnectionsMeta() []*Meta {
+func GetAllConnectionsMeta(forceAll bool) []*Meta {
 	globalConnectionManager.RLock()
 	defer globalConnectionManager.RUnlock()
 	metaList := make([]*Meta, 0)
 	for _, meta := range globalConnectionManager.connectionPool {
+		if !meta.Named && !forceAll {
+			continue
+		}
 		metaList = append(metaList, meta)
 	}
 	return metaList