diff options
| author | Jiffs Maverick <jiffsmaverick@gmail.com> | 2022-11-24 20:22:59 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-11-24 10:22:59 -0800 |
| commit | 4b0430e71d097c0de1f848b09d7aa8b4a74cb4d7 (patch) | |
| tree | 086cd97678732f6dc2057779d082f1f9f1c5e662 /weed/command/filer_sync.go | |
| parent | 15284e2beec73ed819c3e81db450f38c2732e680 (diff) | |
| download | seaweedfs-4b0430e71d097c0de1f848b09d7aa8b4a74cb4d7.tar.xz seaweedfs-4b0430e71d097c0de1f848b09d7aa8b4a74cb4d7.zip | |
[metrics] Add the ability to control bind ip (#4012)
Diffstat (limited to 'weed/command/filer_sync.go')
| -rw-r--r-- | weed/command/filer_sync.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/weed/command/filer_sync.go b/weed/command/filer_sync.go index 4cb97ba07..00afab535 100644 --- a/weed/command/filer_sync.go +++ b/weed/command/filer_sync.go @@ -43,6 +43,7 @@ type SyncOptions struct { bFromTsMs *int64 aProxyByFiler *bool bProxyByFiler *bool + metricsHttpIp *string metricsHttpPort *int concurrency *int clientId int32 @@ -86,6 +87,7 @@ func init() { syncOptions.concurrency = cmdFilerSynchronize.Flag.Int("concurrency", DefaultConcurrencyLimit, "The maximum number of files that will be synced concurrently.") syncCpuProfile = cmdFilerSynchronize.Flag.String("cpuprofile", "", "cpu profile output file") syncMemProfile = cmdFilerSynchronize.Flag.String("memprofile", "", "memory profile output file") + syncOptions.metricsHttpIp = cmdFilerSynchronize.Flag.String("metricsIp", "", "metrics listen ip") syncOptions.metricsHttpPort = cmdFilerSynchronize.Flag.Int("metricsPort", 0, "metrics listen port") syncOptions.clientId = util.RandomInt32() } @@ -119,7 +121,7 @@ func runFilerSynchronize(cmd *Command, args []string) bool { filerB := pb.ServerAddress(*syncOptions.filerB) // start filer.sync metrics server - go statsCollect.StartMetricsServer(*syncOptions.metricsHttpPort) + go statsCollect.StartMetricsServer(*syncOptions.metricsHttpIp, *syncOptions.metricsHttpPort) // read a filer signature aFilerSignature, aFilerErr := replication.ReadFilerSignature(grpcDialOption, filerA) |