.

internal/monitor/monitor.go

@@ -39,55 +39,15 @@ func StartWatch() {
 		zsub.Hub.Publish(topic, value)
 		c.JSON(http.StatusOK, "+OK")
 	})
+	r.GET("/topic/delay", func(c *gin.Context) {
+		topic := c.Query("topic")
+		value := c.Query("value")
+		delay := c.Query("delay")
+
+		zsub.Hub.Delay([]string{"delay", topic, value, delay})
+		c.JSON(http.StatusOK, "+OK")
+	})
 
 	watchAddr := zsub.Conf.Service.Watch
 	r.Run(watchAddr)
-
-	/*dir, _ := os.Getwd()
-	webDir := path.Join(dir, "/public")
-
-	http.Handle("/", http.FileServer(http.Dir(webDir)))
-	http.HandleFunc("/info", info)
-	http.HandleFunc("/cleanup", cleanup)
-	http.HandleFunc("/retimer", retimer)
-	http.HandleFunc("/topic/publish", publish)
-
-	watchAddr := zsub.Conf.Service.Watch
-	log.Println("zhub.watch = ", watchAddr)
-	http.ListenAndServe(watchAddr, nil)*/
 }
-
-/*func publish(w http.ResponseWriter, r *http.Request) {
-	topic := r.FormValue("topic")
-	value := r.FormValue("value")
-	zsub.Hub.Publish(topic, value)
-	renderJson(w, "+ok")
-}
-
-// retimer 重载定时调度
-func retimer(w http.ResponseWriter, _ *http.Request) {
-	zsub.Hub.ReloadTimer()
-	renderJson(w, "+reload timer ok")
-}
-
-func cleanup(w http.ResponseWriter, _ *http.Request) {
-	zsub.Hub.Clearup()
-	renderJson(w, "+OK")
-}
-
-func info(w http.ResponseWriter, _ *http.Request) {
-	info := zsub.Info()
-	renderJson(w, info)
-}
-
-func renderJson(w http.ResponseWriter, d interface{}) {
-	var bytes []byte
-
-	if str, ok := d.(string); ok {
-		bytes = []byte(str)
-	} else {
-		bytes, _ = json.Marshal(d)
-		w.Header().Set("content-type", "application/json; charset=utf-8;")
-	}
-	w.Write(bytes)
-}*/