admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-08 18:18:30 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix use address of loop var (#7433)

Browse Source 
Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
This commit is contained in:
congqixia 2021-09-17 16:21:50 +08:00 committed by GitHub
parent 2de7998477
commit 05efb3a029
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
internal/proxy/metrics_info.go
View File

@ -158,12 +158,13 @@ func getSystemInfoMetrics(
// add query nodes to system topology graph // add query nodes to system topology graph
for _, queryNode := range queryCoordTopology.Cluster.ConnectedNodes { for _, queryNode := range queryCoordTopology.Cluster.ConnectedNodes {
node := queryNode
identifier := uniquegenerator.GetUniqueIntGeneratorIns().GetInt() identifier := uniquegenerator.GetUniqueIntGeneratorIns().GetInt()
identifierMap[queryNode.Name] = identifier identifierMap[queryNode.Name] = identifier
queryNodeTopologyNode := metricsinfo.SystemTopologyNode{ queryNodeTopologyNode := metricsinfo.SystemTopologyNode{
Identifier: identifier, Identifier: identifier,
Connected: nil, Connected: nil,
Infos: &queryNode, Infos: &node,
} }
systemTopology.NodesInfo = append(systemTopology.NodesInfo, queryNodeTopologyNode) systemTopology.NodesInfo = append(systemTopology.NodesInfo, queryNodeTopologyNode)
queryCoordTopologyNode.Connected = append(queryCoordTopologyNode.Connected, metricsinfo.ConnectionEdge{ queryCoordTopologyNode.Connected = append(queryCoordTopologyNode.Connected, metricsinfo.ConnectionEdge{
@ -233,12 +234,13 @@ func getSystemInfoMetrics(
// add data nodes to system topology graph // add data nodes to system topology graph
for _, dataNode := range dataCoordTopology.Cluster.ConnectedNodes { for _, dataNode := range dataCoordTopology.Cluster.ConnectedNodes {
node := dataNode
identifier := uniquegenerator.GetUniqueIntGeneratorIns().GetInt() identifier := uniquegenerator.GetUniqueIntGeneratorIns().GetInt()
identifierMap[dataNode.Name] = identifier identifierMap[dataNode.Name] = identifier
dataNodeTopologyNode := metricsinfo.SystemTopologyNode{ dataNodeTopologyNode := metricsinfo.SystemTopologyNode{
Identifier: identifier, Identifier: identifier,
Connected: nil, Connected: nil,
Infos: &dataNode, Infos: &node,
} }
systemTopology.NodesInfo = append(systemTopology.NodesInfo, dataNodeTopologyNode) systemTopology.NodesInfo = append(systemTopology.NodesInfo, dataNodeTopologyNode)
dataCoordTopologyNode.Connected = append(dataCoordTopologyNode.Connected, metricsinfo.ConnectionEdge{ dataCoordTopologyNode.Connected = append(dataCoordTopologyNode.Connected, metricsinfo.ConnectionEdge{
@ -308,12 +310,13 @@ func getSystemInfoMetrics(
// add index nodes to system topology graph // add index nodes to system topology graph
for _, indexNode := range indexCoordTopology.Cluster.ConnectedNodes { for _, indexNode := range indexCoordTopology.Cluster.ConnectedNodes {
node := indexNode
identifier := uniquegenerator.GetUniqueIntGeneratorIns().GetInt() identifier := uniquegenerator.GetUniqueIntGeneratorIns().GetInt()
identifierMap[indexNode.Name] = identifier identifierMap[indexNode.Name] = identifier
indexNodeTopologyNode := metricsinfo.SystemTopologyNode{ indexNodeTopologyNode := metricsinfo.SystemTopologyNode{
Identifier: identifier, Identifier: identifier,
Connected: nil, Connected: nil,
Infos: &indexNode, Infos: &node,
} }
systemTopology.NodesInfo = append(systemTopology.NodesInfo, indexNodeTopologyNode) systemTopology.NodesInfo = append(systemTopology.NodesInfo, indexNodeTopologyNode)
indexCoordTopologyNode.Connected = append(indexCoordTopologyNode.Connected, metricsinfo.ConnectionEdge{ indexCoordTopologyNode.Connected = append(indexCoordTopologyNode.Connected, metricsinfo.ConnectionEdge{