节点根据健康检查自动上下线

internal/web/actions/default/clusters/cluster/createNode.go

@@ -37,6 +37,33 @@ func (this *CreateNodeAction) RunGet(params struct {
 	}
 	this.Data["leftMenuItems"] = leftMenuItems
 
+	// DNS线路
+	clusterDNSResp, err := this.RPC().NodeClusterRPC().FindEnabledNodeClusterDNS(this.AdminContext(), &pb.FindEnabledNodeClusterDNSRequest{NodeClusterId: params.ClusterId})
+	if err != nil {
+		this.ErrorPage(err)
+		return
+	}
+	dnsRouteMaps := []maps.Map{}
+	this.Data["dnsDomainId"] = 0
+	if clusterDNSResp.Domain != nil {
+		domainId := clusterDNSResp.Domain.Id
+		this.Data["dnsDomainId"] = domainId
+		if domainId > 0 {
+			routesResp, err := this.RPC().DNSDomainRPC().FindAllDNSDomainRoutes(this.AdminContext(), &pb.FindAllDNSDomainRoutesRequest{DnsDomainId: domainId})
+			if err != nil {
+				this.ErrorPage(err)
+				return
+			}
+			for _, route := range routesResp.Routes {
+				dnsRouteMaps = append(dnsRouteMaps, maps.Map{
+					"name": route.Name,
+					"code": route.Code,
+				})
+			}
+		}
+	}
+	this.Data["dnsRoutes"] = dnsRouteMaps
+
 	this.Show()
 }
 
@@ -49,6 +76,9 @@ func (this *CreateNodeAction) RunPost(params struct {
 	SshHost         string
 	SshPort         int
 
+	DnsDomainId int64
+	DnsRoute    string
+
 	Must *actions.Must
 }) {
 	params.Must.
@@ -78,10 +108,12 @@ func (this *CreateNodeAction) RunPost(params struct {
 
 	// 保存
 	createResp, err := this.RPC().NodeRPC().CreateNode(this.AdminContext(), &pb.CreateNodeRequest{
-		Name:      params.Name,
-		ClusterId: params.ClusterId,
-		GroupId:   params.GroupId,
-		Login:     loginInfo,
+		Name:        params.Name,
+		ClusterId:   params.ClusterId,
+		GroupId:     params.GroupId,
+		Login:       loginInfo,
+		DnsDomainId: params.DnsDomainId,
+		DnsRoute:    params.DnsRoute,
 	})
 	if err != nil {
 		this.ErrorPage(err)

internal/web/actions/default/clusters/cluster/index.go

@@ -102,6 +102,7 @@ func (this *IndexAction) RunGet(params struct {
 			"name":        node.Name,
 			"isInstalled": node.IsInstalled,
 			"isOn":        node.IsOn,
+			"isUp":        node.IsUp,
 			"installStatus": maps.Map{
 				"isRunning":  node.InstallStatus.IsRunning,
 				"isFinished": node.InstallStatus.IsFinished,

internal/web/actions/default/clusters/cluster/settings/dns/index.go

@@ -39,6 +39,8 @@ func (this *IndexAction) RunGet(params struct {
 		return
 	}
 	this.Data["dnsName"] = dnsInfoResp.Name
+	this.Data["nodesAutoSync"] = dnsInfoResp.NodesAutoSync
+	this.Data["serversAutoSync"] = dnsInfoResp.ServersAutoSync
 	if dnsInfoResp.Domain != nil {
 		this.Data["domainId"] = dnsInfoResp.Domain.Id
 		this.Data["domainName"] = dnsInfoResp.Domain.Name
@@ -50,8 +52,10 @@ func (this *IndexAction) RunGet(params struct {
 func (this *IndexAction) RunPost(params struct {
 	ClusterId int64
 
-	DnsDomainId int64
-	DnsName     string
+	DnsDomainId     int64
+	DnsName         string
+	NodesAutoSync   bool
+	ServersAutoSync bool
 
 	Must *actions.Must
 	CSRF *actionutils.CSRF
@@ -80,9 +84,11 @@ func (this *IndexAction) RunPost(params struct {
 	}
 
 	_, err := this.RPC().NodeClusterRPC().UpdateNodeClusterDNS(this.AdminContext(), &pb.UpdateNodeClusterDNSRequest{
-		NodeClusterId: params.ClusterId,
-		DnsName:       params.DnsName,
-		DnsDomainId:   params.DnsDomainId,
+		NodeClusterId:   params.ClusterId,
+		DnsName:         params.DnsName,
+		DnsDomainId:     params.DnsDomainId,
+		NodesAutoSync:   params.NodesAutoSync,
+		ServersAutoSync: params.ServersAutoSync,
 	})
 	if err != nil {
 		this.ErrorPage(err)

internal/web/actions/default/clusters/clusterutils/cluster_helper.go

@@ -51,9 +51,9 @@ func (this *ClusterHelper) BeforeAction(action *actions.ActionObject) {
 
 		tabbar := actionutils.NewTabbar()
 		tabbar.Add("集群列表", "", "/clusters", "", false)
-		tabbar.Add("节点", "", "/clusters/cluster?clusterId="+clusterIdString, "server", selectedTabbar == "node")
-		tabbar.Add("设置", "", "/clusters/cluster/settings?clusterId="+clusterIdString, "setting", selectedTabbar == "setting")
-		tabbar.Add("删除", "", "/clusters/cluster/delete?clusterId="+clusterIdString, "trash", selectedTabbar == "delete")
+		tabbar.Add("集群节点", "", "/clusters/cluster?clusterId="+clusterIdString, "server", selectedTabbar == "node")
+		tabbar.Add("集群设置", "", "/clusters/cluster/settings?clusterId="+clusterIdString, "setting", selectedTabbar == "setting")
+		tabbar.Add("删除集群", "", "/clusters/cluster/delete?clusterId="+clusterIdString, "trash", selectedTabbar == "delete")
 
 		{
 			m := tabbar.Add("当前集群："+cluster.Name, "", "/clusters/cluster?clusterId="+clusterIdString, "", false)