From acd75c312a5bef047d7a48b30bbddefb647ebf1c Mon Sep 17 00:00:00 2001 From: xige-16 Date: Tue, 16 Nov 2021 21:49:25 +0800 Subject: [PATCH] [skip ci] Fix golint of WatchDeltaChannels in queryCoord (#11939) Signed-off-by: xige-16 --- internal/querycoord/cluster.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/querycoord/cluster.go b/internal/querycoord/cluster.go index 243e8b9988..1ec5a4d0cd 100644 --- a/internal/querycoord/cluster.go +++ b/internal/querycoord/cluster.go @@ -293,18 +293,18 @@ func (c *queryNodeCluster) watchDeltaChannels(ctx context.Context, nodeID int64, if node, ok := c.nodes[nodeID]; ok { err := node.watchDeltaChannels(ctx, in) if err != nil { - log.Debug("WatchDeltaChannels: queryNode watch dm channel error", zap.String("error", err.Error())) + log.Debug("watchDeltaChannels: queryNode watch dm channel error", zap.String("error", err.Error())) return err } err = c.clusterMeta.setDeltaChannel(in.CollectionID, in.Infos) if err != nil { - log.Debug("WatchDeltaChannels: queryNode watch delta channel error", zap.String("error", err.Error())) + log.Debug("watchDeltaChannels: queryNode watch delta channel error", zap.String("error", err.Error())) return err } return nil } - return errors.New("WatchDeltaChannels: Can't find query node by nodeID ") + return errors.New("watchDeltaChannels: Can't find query node by nodeID ") } func (c *queryNodeCluster) hasWatchedDeltaChannel(ctx context.Context, nodeID int64, collectionID UniqueID) bool {