Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

etcd: glue

Browse Source
This commit is contained in:
Xiang Li
2014-06-26 13:48:59 -07:00
committed by Yicheng Qin
parent 8eac28350d
commit 7be945f59b
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
raft/node.go
View File

@@ -12,7 +12,7 @@ type Interface interface {
type tick int
type config struct {
type Config struct {
NodeId int
Addr string
}
@@ -50,9 +50,11 @@ func (n *Node) propose(t int, data []byte) {
n.Step(Message{Type: msgProp, Entries: []Entry{{Type: t, Data: data}}})
}
func (n *Node) Add(id int, addr string) { n.updateConf(AddNode, &config{NodeId: id, Addr: addr}) }
func (n *Node) Campaign() { n.Step(Message{Type: msgHup}) }
func (n *Node) Remove(id int) { n.updateConf(RemoveNode, &config{NodeId: id}) }
func (n *Node) Add(id int, addr string) { n.updateConf(AddNode, &Config{NodeId: id, Addr: addr}) }
func (n *Node) Remove(id int) { n.updateConf(RemoveNode, &Config{NodeId: id}) }
func (n *Node) Msgs() []Message { return n.sm.Msgs() }
@@ -83,14 +85,14 @@ func (n *Node) Next() []Entry {
switch ents[i].Type {
case Normal:
case AddNode:
c := new(config)
c := new(Config)
if err := json.Unmarshal(ents[i].Data, c); err != nil {
golog.Println(err)
continue
}
n.sm.addNode(c.NodeId)
case RemoveNode:
c := new(config)
c := new(Config)
if err := json.Unmarshal(ents[i].Data, c); err != nil {
golog.Println(err)
continue
@@ -123,7 +125,7 @@ func (n *Node) Tick() {
}
}
func (n *Node) updateConf(t int, c *config) {
func (n *Node) updateConf(t int, c *Config) {
data, err := json.Marshal(c)
if err != nil {
panic(err)