| | |
|---|
| | | import ( |
|---|
| | | "context" |
|---|
| | | "flag" |
|---|
| | | "fmt" |
|---|
| | | _ "net/http/pprof" |
|---|
| | | "os" |
|---|
| | | "os/signal" |
|---|
| | |
|---|
| | | Proc: *proc, |
|---|
| | | Channel: nil, |
|---|
| | | PubTopic: pubTopics, |
|---|
| | | SubTopic: []string{versionControlS.AuthorizationUpdateTopic}, |
|---|
| | | SubTopic: []string{versionControlS.AuthorizationUpdateTopic, "sync-proc-message-to-serf"}, |
|---|
| | | SubNetTopic: []string{}, |
|---|
| | | } |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | bhomedbapi.InitGetNetNode(ms.GetLocalNetNodeByTopic) |
|---|
| | | bhomedbapi.InitDoReq(ms.RequestOnly) |
|---|
| | | //bhomedbapi.InitLog(logger.Debug) |
|---|
| | | bhomedbapi.InitLog(logger.Debug) |
|---|
| | | |
|---|
| | | //util.AuthCheck(ctx) //授权检查 |
|---|
| | | |
|---|
| | |
|---|
| | | funcMap[urlPrefix+"/cluster/updateClusterName"] = clusterController.UpdateClusterName |
|---|
| | | funcMap[urlPrefix+"/cluster/leave"] = clusterController.Leave |
|---|
| | | funcMap[urlPrefix+"/cluster/findIpByNode"] = clusterController.FindIpByNode |
|---|
| | | funcMap[urlPrefix+"/cluster/status"] = clusterController.GetClusterStat |
|---|
| | | |
|---|
| | | sysMenuC := new(controllers.SysMenuController) |
|---|
| | | funcMap["/data/api-u/sysmenus/tree"] = sysMenuC.MenuTree |
|---|
| | |
|---|
| | | for key, _ := range funcMap { |
|---|
| | | pubTopics = append(pubTopics, key) |
|---|
| | | } |
|---|
| | | |
|---|
| | | return funcMap, pubTopics |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 测试接收全网消息 |
|---|
| | | func dealSubMsg(ctx context.Context, ms *bhomeclient.MicroNode) { |
|---|
| | | fmt.Println("dealSubMsg") |
|---|
| | | for { |
|---|
| | | select { |
|---|
| | | case <-ctx.Done(): |
|---|
