test/Rainbond
1
0
Fork 0
mirror of https://gitee.com/rainbond/Rainbond.git synced 2024-12-02 03:37:46 +08:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

[REV] optimize master node update hosts file

Browse Source
This commit is contained in:
bay1ts 2017-12-11 19:15:58 +08:00
parent b431e403b2
commit 6a5731f0bc
1 changed files with 17 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
pkg/node/masterserver/nodecluster.go
View File

@ -42,6 +42,7 @@ import (
"github.com/goodrain/rainbond/pkg/util" "github.com/goodrain/rainbond/pkg/util"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/watch" "k8s.io/apimachinery/pkg/watch"
"os/exec"
) )
//NodeCluster 节点管理器 //NodeCluster 节点管理器
@ -179,6 +180,20 @@ func (n *NodeCluster) GetNode(id string) *model.HostNode {
} }
return nil return nil
} }
func RegToHost(node *model.HostNode,opt string) {
uuid:=node.ID
internalIP:=node.InternalIP
cmd := exec.Command("bash", "/usr/share/gr-rainbond-node/gaops/jobs/cron/common/node_update_hosts.sh",uuid+" "+internalIP+" "+opt)
outbuf:=bytes.NewBuffer(nil)
cmd.Stdout=outbuf
err:=cmd.Run()
if err != nil {
logrus.Errorf("error update /etc/hosts,details %s",err.Error())
return
}
logrus.Infof("update /etc/hosts %s %s success",uuid,internalIP)
}
func (n *NodeCluster) watchNodes() { func (n *NodeCluster) watchNodes() {
ch := n.client.Watch(option.Config.NodePath, client.WithPrefix()) ch := n.client.Watch(option.Config.NodePath, client.WithPrefix())
onlineCh := n.client.Watch(option.Config.OnlineNodePath, client.WithPrefix()) onlineCh := n.client.Watch(option.Config.OnlineNodePath, client.WithPrefix())
@ -191,10 +206,12 @@ func (n *NodeCluster) watchNodes() {
switch { switch {
case ev.IsCreate(), ev.IsModify(): case ev.IsCreate(), ev.IsModify():
if node := n.getNodeFromKV(ev.Kv); node != nil { if node := n.getNodeFromKV(ev.Kv); node != nil {
RegToHost(node,"add")
n.CacheNode(node) n.CacheNode(node)
} }
case ev.Type == client.EventTypeDelete: case ev.Type == client.EventTypeDelete:
if node := n.getNodeFromKey(string(ev.Kv.Key)); node != nil { if node := n.getNodeFromKey(string(ev.Kv.Key)); node != nil {
RegToHost(node,"del")
n.RemoveNode(node) n.RemoveNode(node)
} }
} }