mirror of
https://github.com/chrislusf/seaweedfs
synced 2024-06-28 05:12:13 +02:00
33 lines
774 B
Go
33 lines
774 B
Go
package operation
|
|
|
|
import (
|
|
"encoding/json"
|
|
|
|
"github.com/chrislusf/seaweedfs/weed/glog"
|
|
"github.com/chrislusf/seaweedfs/weed/util"
|
|
)
|
|
|
|
type ClusterStatusResult struct {
|
|
IsLeader bool `json:"IsLeader,omitempty"`
|
|
Leader string `json:"Leader,omitempty"`
|
|
Peers []string `json:"Peers,omitempty"`
|
|
}
|
|
|
|
func ListMasters(server string) (leader string, peers []string, err error) {
|
|
jsonBlob, err := util.Get("http://" + server + "/cluster/status")
|
|
glog.V(2).Info("list masters result :", string(jsonBlob))
|
|
if err != nil {
|
|
return "", nil, err
|
|
}
|
|
var ret ClusterStatusResult
|
|
err = json.Unmarshal(jsonBlob, &ret)
|
|
if err != nil {
|
|
return "", nil, err
|
|
}
|
|
peers = ret.Peers
|
|
if ret.IsLeader {
|
|
peers = append(peers, ret.Leader)
|
|
}
|
|
return ret.Leader, peers, nil
|
|
}
|