| | |
| | | var body SWFSInfo |
| | | c.BindJSON(&body) |
| | | role := body.Role |
| | | nowPeers := GetNowPeersList() |
| | | if role == "master" { |
| | | AsMaster(nowPeers) |
| | | AddNewMasterToPeers() |
| | | AsMaster() |
| | | util.ResponseFormat(c, code.AddSuccess, "加入节点成功") |
| | | return |
| | | } else if role == "volume" { |
| | | AsVolume(nowPeers) |
| | | AsVolume() |
| | | util.ResponseFormat(c, code.AddSuccess, "加入节点成功") |
| | | return |
| | | } else { |
| | |
| | | } |
| | | |
| | | func (sc *SeaweedfsController) RoleOfVolumeToMasterController(c *gin.Context) { |
| | | AsMaster(GetNowPeersList()) |
| | | AsMaster() |
| | | } |
| | | |
| | | func (sc *SeaweedfsController) RestartMasterController(c *gin.Context) { |
| | |
| | | } |
| | | |
| | | //作为数据节点加入 |
| | | func AsVolume(nowPeers []interface{}) { |
| | | func AsVolume() { |
| | | ReplaceLineContentBySearch(StartScriptAsVolume, config.Server.ScriptPath, StartServerScript) |
| | | StartServer(config.Server.ScriptPath) |
| | | } |
| | | |
| | | //作为主节点加入(默认包含数据节点) |
| | | func AsMaster(nowPeers []interface{}) { |
| | | AddNewMasterToPeers() |
| | | func AsMaster() { |
| | | nowPeers := GetNowPeersList() |
| | | RequestMasterNodesOperation(nowPeers) |
| | | } |
| | | |