aboutsummaryrefslogtreecommitdiff
path: root/weed/server/volume_grpc_client_to_master.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/volume_grpc_client_to_master.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/volume_grpc_client_to_master.go')
-rw-r--r--weed/server/volume_grpc_client_to_master.go4
1 files changed, 4 insertions, 0 deletions
diff --git a/weed/server/volume_grpc_client_to_master.go b/weed/server/volume_grpc_client_to_master.go
index d493b7233..731675b48 100644
--- a/weed/server/volume_grpc_client_to_master.go
+++ b/weed/server/volume_grpc_client_to_master.go
@@ -86,6 +86,10 @@ func (vs *VolumeServer) doHeartbeat(ctx context.Context, masterNode, masterGrpcA
doneChan <- nil
return
}
+ if in.GetMetricsAddress() != "" && vs.MetricsAddress != in.GetMetricsAddress() {
+ vs.MetricsAddress = in.GetMetricsAddress()
+ vs.MetricsIntervalSec = int(in.GetMetricsIntervalSeconds())
+ }
}
}()