添加主节点变更和主动切换功能

zhangzengfei

2023-10-20 71b8885babe6dfd25c91b007018347c0c1bfac74

 system-service/main.go

@@ -180,6 +180,7 @@
   funcMap[urlPrefix+"/cluster/leave"] = clusterController.Leave
   funcMap[urlPrefix+"/cluster/findIpByNode"] = clusterController.FindIpByNode
   funcMap[urlPrefix+"/cluster/status"] = clusterController.GetClusterStat
   funcMap[urlPrefix+"/cluster/update2Master"] = clusterController.Update2Master

   sysMenuC := new(controllers.SysMenuController)
   funcMap["/data/api-u/sysmenus/tree"] = sysMenuC.MenuTree
@@ -285,7 +286,7 @@
      case <-ctx.Done():
         return
      case msg := <-ms.SubCh:
         logger.Debug("recv sub msg topic:", string(msg.Topic), " data:", string(msg.Data))
         logger.Debug("recv sub msg topic:", string(msg.Topic), " data len:", len(msg.Data))
         service.PersistentWrapper(string(msg.Topic), msg.Data)
      }
   }