aboutsummaryrefslogtreecommitdiff
path: root/weed/server/master_server.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-11-02 23:38:45 -0700
committerChris Lu <chris.lu@gmail.com>2021-11-02 23:38:45 -0700
commit5160eb08f7665409221ebb0b9db6f4820e29bed3 (patch)
treef63464dd23ee0742bd96afe52826b477a775dc5e /weed/server/master_server.go
parent18bfbf62fcc64be380293ce797ab23f785c01760 (diff)
downloadseaweedfs-5160eb08f7665409221ebb0b9db6f4820e29bed3.tar.xz
seaweedfs-5160eb08f7665409221ebb0b9db6f4820e29bed3.zip
shell: optionally read filer address from master
Diffstat (limited to 'weed/server/master_server.go')
-rw-r--r--weed/server/master_server.go3
1 files changed, 3 insertions, 0 deletions
diff --git a/weed/server/master_server.go b/weed/server/master_server.go
index 3b3b1c94b..653c4e003 100644
--- a/weed/server/master_server.go
+++ b/weed/server/master_server.go
@@ -67,6 +67,8 @@ type MasterServer struct {
MasterClient *wdclient.MasterClient
adminLocks *AdminLocks
+
+ Cluster *Cluster
}
func NewMasterServer(r *mux.Router, option *MasterOption, peers []pb.ServerAddress) *MasterServer {
@@ -103,6 +105,7 @@ func NewMasterServer(r *mux.Router, option *MasterOption, peers []pb.ServerAddre
grpcDialOption: grpcDialOption,
MasterClient: wdclient.NewMasterClient(grpcDialOption, "master", option.Master, "", peers),
adminLocks: NewAdminLocks(),
+ Cluster: NewCluster(),
}
ms.boundedLeaderChan = make(chan int, 16)