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

[skip ci] Fix golint of cluster (#12737)

Browse Source 
Signed-off-by: xige-16 <xi.ge@zilliz.com>
This commit is contained in:
xige-16 2021-12-06 11:43:34 +08:00 committed by GitHub
parent 38956215aa
commit 9a208254d8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
internal/querycoord/cluster.go
View File

@ -322,7 +322,7 @@ func (c *queryNodeCluster) watchDmChannels(ctx context.Context, nodeID int64, in
return nil return nil
} }
return fmt.Errorf("watchDmChannels: Can't find query node by nodeID, nodeID = %d", nodeID) return fmt.Errorf("watchDmChannels: can't find query node by nodeID, nodeID = %d", nodeID)
} }
func (c *queryNodeCluster) watchDeltaChannels(ctx context.Context, nodeID int64, in *querypb.WatchDeltaChannelsRequest) error { func (c *queryNodeCluster) watchDeltaChannels(ctx context.Context, nodeID int64, in *querypb.WatchDeltaChannelsRequest) error {
@ -348,7 +348,7 @@ func (c *queryNodeCluster) watchDeltaChannels(ctx context.Context, nodeID int64,
return nil return nil
} }
return fmt.Errorf("watchDeltaChannels: Can't find query node by nodeID, nodeID = %d", nodeID) return fmt.Errorf("watchDeltaChannels: can't find query node by nodeID, nodeID = %d", nodeID)
} }
func (c *queryNodeCluster) hasWatchedDeltaChannel(ctx context.Context, nodeID int64, collectionID UniqueID) bool { func (c *queryNodeCluster) hasWatchedDeltaChannel(ctx context.Context, nodeID int64, collectionID UniqueID) bool {
@ -549,7 +549,7 @@ func (c *queryNodeCluster) getNumDmChannels(nodeID int64) (int, error) {
defer c.RUnlock() defer c.RUnlock()
if _, ok := c.nodes[nodeID]; !ok { if _, ok := c.nodes[nodeID]; !ok {
return 0, fmt.Errorf("getNumDmChannels: Can't find query node by nodeID, nodeID = %d", nodeID) return 0, fmt.Errorf("getNumDmChannels: can't find query node by nodeID, nodeID = %d", nodeID)
} }
numChannel := 0 numChannel := 0
@ -569,7 +569,7 @@ func (c *queryNodeCluster) getNumSegments(nodeID int64) (int, error) {
defer c.RUnlock() defer c.RUnlock()
if _, ok := c.nodes[nodeID]; !ok { if _, ok := c.nodes[nodeID]; !ok {
return 0, fmt.Errorf("getNumSegments: Can't find query node by nodeID, nodeID = %d", nodeID) return 0, fmt.Errorf("getNumSegments: can't find query node by nodeID, nodeID = %d", nodeID)
} }
numSegment := 0 numSegment := 0