milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[skip ci]Fix golint for watchNodeLoop (#13199) 

Signed-off-by: xige-16 <xi.ge@zilliz.com>
pull/13213/head
xige-16 2021-12-10 21:55:48 +08:00 committed by GitHub
parent f85c1e8f1e
commit 9ccbffc4b1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
internal/querycoord/query_coord.go
View File

@ -300,7 +300,7 @@ func (qc *QueryCoord) watchNodeLoop() {
ctx, cancel := context.WithCancel(qc.loopCtx) ctx, cancel := context.WithCancel(qc.loopCtx)
defer cancel() defer cancel()
defer qc.loopWg.Done() defer qc.loopWg.Done()
log.Debug("query coordinator start watch node loop") log.Debug("QueryCoord start watch node loop")
offlineNodes, err := qc.cluster.offlineNodes() offlineNodes, err := qc.cluster.offlineNodes()
if err == nil { if err == nil {
@ -343,18 +343,18 @@ func (qc *QueryCoord) watchNodeLoop() {
switch event.EventType { switch event.EventType {
case sessionutil.SessionAddEvent: case sessionutil.SessionAddEvent:
serverID := event.Session.ServerID serverID := event.Session.ServerID
log.Debug("start add a queryNode to cluster", zap.Any("nodeID", serverID)) log.Debug("start add a QueryNode to cluster", zap.Any("nodeID", serverID))
err := qc.cluster.registerNode(ctx, event.Session, serverID, disConnect) err := qc.cluster.registerNode(ctx, event.Session, serverID, disConnect)
if err != nil { if err != nil {
log.Error("query node failed to register", zap.Int64("nodeID", serverID), zap.String("error info", err.Error())) log.Error("QueryCoord failed to register a QueryNode", zap.Int64("nodeID", serverID), zap.String("error info", err.Error()))
} }
qc.metricsCacheManager.InvalidateSystemInfoMetrics() qc.metricsCacheManager.InvalidateSystemInfoMetrics()
case sessionutil.SessionDelEvent: case sessionutil.SessionDelEvent:
serverID := event.Session.ServerID serverID := event.Session.ServerID
log.Debug("get a del event after queryNode down", zap.Int64("nodeID", serverID)) log.Debug("get a del event after QueryNode down", zap.Int64("nodeID", serverID))
nodeExist := qc.cluster.hasNode(serverID) nodeExist := qc.cluster.hasNode(serverID)
if !nodeExist { if !nodeExist {
log.Error("queryNode not exist", zap.Int64("nodeID", serverID)) log.Error("QueryNode not exist", zap.Int64("nodeID", serverID))
continue continue
} }