mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2024-01-19 02:48:24 +00:00
Fix binding metrics to ipv6 (#4286)
* Fix binding metrics to ipv6 * Update weed/stats/metrics.go --------- Co-authored-by: Chris Lu <chrislusf@users.noreply.github.com>
This commit is contained in:
parent
889ecf5c9d
commit
244385bf0d
|
@ -1,7 +1,6 @@
|
||||||
package stats
|
package stats
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
|
||||||
"log"
|
"log"
|
||||||
"net"
|
"net"
|
||||||
"net/http"
|
"net/http"
|
||||||
|
@ -282,12 +281,21 @@ func LoopPushingMetric(name, instance, addr string, intervalSeconds int) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func JoinHostPort(host string, port int) string {
|
||||||
|
portStr := strconv.Itoa(port)
|
||||||
|
if strings.HasPrefix(host, "[") && strings.HasSuffix(host, "]") {
|
||||||
|
return host + ":" + portStr
|
||||||
|
}
|
||||||
|
return net.JoinHostPort(host, portStr)
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
func StartMetricsServer(ip string, port int) {
|
func StartMetricsServer(ip string, port int) {
|
||||||
if port == 0 {
|
if port == 0 {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
http.Handle("/metrics", promhttp.HandlerFor(Gather, promhttp.HandlerOpts{}))
|
http.Handle("/metrics", promhttp.HandlerFor(Gather, promhttp.HandlerOpts{}))
|
||||||
log.Fatal(http.ListenAndServe(fmt.Sprintf("%s:%d", ip, port), nil))
|
log.Fatal(http.ListenAndServe(JoinHostPort(ip, port), nil))
|
||||||
}
|
}
|
||||||
|
|
||||||
func SourceName(port uint32) string {
|
func SourceName(port uint32) string {
|
||||||
|
|
Loading…
Reference in a new issue