diff options
| author | chrislu <chris.lu@gmail.com> | 2022-07-03 00:55:37 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-07-28 23:22:52 -0700 |
| commit | f25e273e328a9959f4dcef13c5f78e427c0bf7a0 (patch) | |
| tree | 66168b00670b2dc0d8a52f42395b3e9918c2e657 /weed/cluster/cluster.go | |
| parent | 68065128b83997365a0f267799026b0e520b9816 (diff) | |
| download | seaweedfs-f25e273e328a9959f4dcef13c5f78e427c0bf7a0.tar.xz seaweedfs-f25e273e328a9959f4dcef13c5f78e427c0bf7a0.zip | |
display data center and rack in cluster.ps
Diffstat (limited to 'weed/cluster/cluster.go')
| -rw-r--r-- | weed/cluster/cluster.go | 32 |
1 files changed, 20 insertions, 12 deletions
diff --git a/weed/cluster/cluster.go b/weed/cluster/cluster.go index 1802ecda0..0d9886911 100644 --- a/weed/cluster/cluster.go +++ b/weed/cluster/cluster.go @@ -34,10 +34,12 @@ type RackBrokers struct { } type ClusterNode struct { - Address pb.ServerAddress - Version string - counter int - CreatedTs time.Time + Address pb.ServerAddress + Version string + counter int + CreatedTs time.Time + DataCenter DataCenter + Rack Rack } type Cluster struct { @@ -78,10 +80,12 @@ func (cluster *Cluster) AddClusterNode(ns, nodeType string, dataCenter DataCente return nil } filers.filers[address] = &ClusterNode{ - Address: address, - Version: version, - counter: 1, - CreatedTs: time.Now(), + Address: address, + Version: version, + counter: 1, + CreatedTs: time.Now(), + DataCenter: dataCenter, + Rack: rack, } return cluster.ensureFilerLeaders(filers, true, filerGroup, nodeType, address) case BrokerType: @@ -92,12 +96,14 @@ func (cluster *Cluster) AddClusterNode(ns, nodeType string, dataCenter DataCente existingDataCenterBrokers = &DataCenterBrokers{ brokers: make(map[Rack]*RackBrokers), } + cluster.brokers[dataCenter] = existingDataCenterBrokers } existingRackBrokers, foundRack := existingDataCenterBrokers.brokers[rack] if !foundRack { existingRackBrokers = &RackBrokers{ brokers: make(map[pb.ServerAddress]*ClusterNode), } + existingDataCenterBrokers.brokers[rack] = existingRackBrokers } if existingBroker, found := existingRackBrokers.brokers[address]; found { @@ -105,10 +111,12 @@ func (cluster *Cluster) AddClusterNode(ns, nodeType string, dataCenter DataCente return nil } existingRackBrokers.brokers[address] = &ClusterNode{ - Address: address, - Version: version, - counter: 1, - CreatedTs: time.Now(), + Address: address, + Version: version, + counter: 1, + CreatedTs: time.Now(), + DataCenter: dataCenter, + Rack: rack, } return []*master_pb.KeepConnectedResponse{ { |