aboutsummaryrefslogtreecommitdiff
path: root/weed/server/filer_server.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2019-06-17 14:51:47 -0700
committerChris Lu <chris.lu@gmail.com>2019-06-17 14:51:47 -0700
commitd8ed73926dc79aaea57e9eb305c718e82dace64c (patch)
treee0dab86e8ddf7a79b2330b9eeb6654378a255df1 /weed/server/filer_server.go
parent68d1bef23671f353f65d89b73907edf5ce6918fc (diff)
downloadseaweedfs-d8ed73926dc79aaea57e9eb305c718e82dace64c.tar.xz
seaweedfs-d8ed73926dc79aaea57e9eb305c718e82dace64c.zip
volume servers get metrics address and interval from the master
Diffstat (limited to 'weed/server/filer_server.go')
-rw-r--r--weed/server/filer_server.go5
1 files changed, 4 insertions, 1 deletions
diff --git a/weed/server/filer_server.go b/weed/server/filer_server.go
index d437f0597..64c738739 100644
--- a/weed/server/filer_server.go
+++ b/weed/server/filer_server.go
@@ -87,7 +87,10 @@ func NewFilerServer(defaultMux, readonlyMux *http.ServeMux, option *FilerOption)
readonlyMux.HandleFunc("/", fs.readonlyFilerHandler)
}
- stats.StartPushingMetric("filer", stats.SourceName(option.Port), stats.FilerGather, option.MetricsAddress, option.MetricsIntervalSec)
+ go stats.LoopPushingMetric("filer", stats.SourceName(option.Port), stats.FilerGather,
+ func() (addr string, intervalSeconds int) {
+ return option.MetricsAddress, option.MetricsIntervalSec
+ })
return fs, nil
}