From ea86b44d8319213b4c44ee2a42c22a873a1219c8 Mon Sep 17 00:00:00 2001 From: "joy.zhou" Date: Fri, 16 Aug 2019 18:01:35 +0800 Subject: [PATCH] remove connections --- broker/{kafka.go => bridge.go} | 0 broker/http.go | 13 ------------- 2 files changed, 13 deletions(-) rename broker/{kafka.go => bridge.go} (100%) diff --git a/broker/kafka.go b/broker/bridge.go similarity index 100% rename from broker/kafka.go rename to broker/bridge.go diff --git a/broker/http.go b/broker/http.go index f75d461..b0bdc09 100644 --- a/broker/http.go +++ b/broker/http.go @@ -22,19 +22,6 @@ func InitHTTPMoniter(b *Broker) { c.JSON(200, &resp) }) - router.GET("api/v1/connections", func(c *gin.Context) { - num := 0 - b.clients.Range(func(key, value interface{}) bool { - num++ - return true - }) - resp := map[string]int{ - "code": 0, - "counts": num, - } - c.JSON(200, &resp) - }) - router.GET("api/v1/nodes", func(c *gin.Context) { num := 0 b.clients.Range(func(key, value interface{}) bool {