基于serf的数据库同步模块库
zhangzengfei
2023-05-15 12f52d5835388f22fdecb2a890d58e5425688c8e
agent.go
@@ -60,6 +60,7 @@
   NodeID      string `json:"nodeID"`
   NodeAddress string `json:"nodeAddress"`
   IsAlive     int    `json:"isAlive"`
   Role        string `json:"role"`
}
// Create create serf agent with config
@@ -762,6 +763,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)
   }