基于serf的数据库同步模块库
zhangzengfei
2023-05-15 8395ef00a651448cc7172c98a36014f98888ac9d
agent.go
@@ -51,6 +51,7 @@
   NodeID            string       `json:"nodeID"`
   NodeAddress       string       `json:"nodeAddress"`
   IsAlive           int          `json:"isAlive"`
   Role               string       `json:"role"`
}
// Create create serf agent with config
@@ -406,6 +407,7 @@
      node.NodeAddress = mb.Addr.String() + ":" + strconv.Itoa(int(mb.Port))
      node.IsAlive = int(mb.Status)
      node.ClusterID = mb.Tags[tagKeyClusterID]
      node.Role = mb.Tags["role"]
      nodes = append(nodes, node)
   }