test/Rainbond
1
0
Fork 0
mirror of https://gitee.com/rainbond/Rainbond.git synced 2024-12-02 03:37:46 +08:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

[ADD] mq healthcheck api

Browse Source
This commit is contained in:
zhoujunhao 2018-07-13 12:20:16 +08:00
parent 9fc2bcbcbc
commit 5c228878fa
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
mq/api/api.go
View File

@ -43,6 +43,7 @@ import (
"github.com/prometheus/client_golang/prometheus" "github.com/prometheus/client_golang/prometheus"
"github.com/prometheus/client_golang/prometheus/promhttp" "github.com/prometheus/client_golang/prometheus/promhttp"
"github.com/prometheus/common/version" "github.com/prometheus/common/version"
httputil "github.com/goodrain/rainbond/util/http"
) )
type Manager struct { type Manager struct {
@ -105,6 +106,7 @@ func NewManager(c option.Config) (*Manager, error) {
} }
go func() { go func() {
Prometheus() Prometheus()
health()
if err := http.ListenAndServe(":6301", nil); err != nil { if err := http.ListenAndServe(":6301", nil); err != nil {
logrus.Error("mq pprof listen error.", err.Error()) logrus.Error("mq pprof listen error.", err.Error())
} }
@ -185,3 +187,11 @@ func Prometheus() {
prometheus.MustRegister(exporter) prometheus.MustRegister(exporter)
http.Handle("/metrics", promhttp.Handler()) http.Handle("/metrics", promhttp.Handler())
} }
func health() {
http.HandleFunc("/health", checkHalth)
}
func checkHalth(w http.ResponseWriter, r *http.Request) {
httputil.ReturnSuccess(r, w, map[string]string{"status": "health", "info": "mq service health"})
}