|
@@ -134,7 +134,7 @@ func (c *JoinCommand) Apply(raftServer *raft.Server) (interface{}, error) {
|
|
|
|
|
|
|
|
// add machine in etcd storage
|
|
// add machine in etcd storage
|
|
|
nodeName := fmt.Sprintf("%s%d", "node", raftServer.CommitIndex())
|
|
nodeName := fmt.Sprintf("%s%d", "node", raftServer.CommitIndex())
|
|
|
- key := path.Join("machines", nodeName)
|
|
|
|
|
|
|
+ key := path.Join("_etcd/machines", nodeName)
|
|
|
value := fmt.Sprintf("%s,%d,%d", c.Hostname, c.RaftPort, c.ClientPort)
|
|
value := fmt.Sprintf("%s,%d,%d", c.Hostname, c.RaftPort, c.ClientPort)
|
|
|
etcdStore.Set(key, value, time.Unix(0, 0), raftServer.CommitIndex())
|
|
etcdStore.Set(key, value, time.Unix(0, 0), raftServer.CommitIndex())
|
|
|
|
|
|