mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2024-12-24 09:27:54 +08:00
721c6197f9
* skip deltaBeat https://github.com/seaweedfs/seaweedfs/issues/3629 * fix GrpcPort * skip url :0 * skip empty DataCenter or Rack * skip empty heartbeat Ip * dell msg add DataCenter * comment todo * fix
45 lines
811 B
Go
45 lines
811 B
Go
package topology
|
|
|
|
import (
|
|
"encoding/xml"
|
|
)
|
|
|
|
type loc struct {
|
|
dcName string
|
|
rackName string
|
|
}
|
|
type rack struct {
|
|
Name string `xml:"name,attr"`
|
|
Ips []string `xml:"Ip"`
|
|
}
|
|
type dataCenter struct {
|
|
Name string `xml:"name,attr"`
|
|
Racks []rack `xml:"Rack"`
|
|
}
|
|
type topology struct {
|
|
DataCenters []dataCenter `xml:"DataCenter"`
|
|
}
|
|
type Configuration struct {
|
|
XMLName xml.Name `xml:"Configuration"`
|
|
Topo topology `xml:"Topology"`
|
|
}
|
|
|
|
func (c *Configuration) String() string {
|
|
if b, e := xml.MarshalIndent(c, " ", " "); e == nil {
|
|
return string(b)
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (c *Configuration) Locate(ip string, dcName string, rackName string) (dc string, rack string) {
|
|
if dcName == "" {
|
|
dcName = "DefaultDataCenter"
|
|
}
|
|
|
|
if rackName == "" {
|
|
rackName = "DefaultRack"
|
|
}
|
|
|
|
return dcName, rackName
|
|
}
|