floraachy
/
console
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update enroll staus

This commit is contained in:
medcl 2023-10-19 14:18:48 +08:00
parent 4f949cfd40
commit f6fe743a88
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
modules/agent/api/elasticsearch.go
View File

@ -18,7 +18,7 @@ import (
) )
func refreshNodesInfo(inst *model.Instance) (*elastic.DiscoveryResult, error) { func refreshNodesInfo(inst *model.Instance) (*elastic.DiscoveryResult, error) {
oldNodesInfo, err := getEnrolledNodesByAgent(inst) enrolledNodesByAgent, err := getEnrolledNodesByAgent(inst)
if err != nil { if err != nil {
return nil, fmt.Errorf("error on get binding nodes info: %w", err) return nil, fmt.Errorf("error on get binding nodes info: %w", err)
} }
@ -30,9 +30,9 @@ func refreshNodesInfo(inst *model.Instance) (*elastic.DiscoveryResult, error) {
//TODO return already biding nodes info ?? //TODO return already biding nodes info ??
return nil, fmt.Errorf("error on get nodes info from agent: %w", err) return nil, fmt.Errorf("error on get nodes info from agent: %w", err)
} }
for nodeID, node := range nodesInfo.Nodes { for nodeID, node := range nodesInfo.Nodes {
v, ok := oldNodesInfo[nodeID]
v, ok := enrolledNodesByAgent[nodeID]
if ok { if ok {
node.ClusterID = v.ClusterID node.ClusterID = v.ClusterID
node.Enrolled = true node.Enrolled = true
@ -50,7 +50,7 @@ func refreshNodesInfo(inst *model.Instance) (*elastic.DiscoveryResult, error) {
// { // {
// //node was not recognized by agent, need auth? // //node was not recognized by agent, need auth?
// if node.HttpPort != "" { // if node.HttpPort != "" {
// for _, v := range oldNodesInfo { // for _, v := range enrolledNodesByAgent {
// if v.PublishAddress != "" { // if v.PublishAddress != "" {
// if util.UnifyLocalAddress(v.PublishAddress) == util.UnifyLocalAddress(node.PublishAddress) { // if util.UnifyLocalAddress(v.PublishAddress) == util.UnifyLocalAddress(node.PublishAddress) {
// node.ClusterID = v.ClusterID // node.ClusterID = v.ClusterID