From 2539dd45935a0b5cd65d7093bc7efc7017c329fe Mon Sep 17 00:00:00 2001 From: XuanYang-cn Date: Fri, 24 Sep 2021 20:44:05 +0800 Subject: [PATCH] [skip-ci]Fix golint in data_node.go (#8462) Signed-off-by: yangxuan --- internal/datanode/data_node.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/internal/datanode/data_node.go b/internal/datanode/data_node.go index 54d7ac8ac4..471a86ae50 100644 --- a/internal/datanode/data_node.go +++ b/internal/datanode/data_node.go @@ -49,6 +49,7 @@ import ( ) const ( + // RPCConnectionTimeout used to set the timeout for rpc request RPCConnectionTimeout = 30 * time.Second // MetricRequestsTotal used to count the num of total requests @@ -75,7 +76,6 @@ const illegalRequestErrStr = "Illegal request" // `vchan2SyncService` is a map of vchannlName to dataSyncService, so that datanode // has ability to scale flowgraph. // `vchan2FlushCh` holds flush-signal channels for every flowgraph. - // `clearSignal` is a signal channel for releasing the flowgraph resources. // `segmentCache` stores all flushing and flushed segments. type DataNode struct { @@ -325,6 +325,7 @@ func (node *DataNode) ReleaseDataSyncService(vchanName string) { log.Debug("Release flowgraph resources end", zap.String("Vchannel", vchanName)) } +// FilterThreshold is the start time ouf DataNode var FilterThreshold Timestamp // Start will update DataNode state to HEALTHY @@ -548,6 +549,7 @@ func (node *DataNode) FlushSegments(ctx context.Context, req *datapb.FlushSegmen return status, nil } +// Stop will release DataNode resources and shutdown datanode func (node *DataNode) Stop() error { node.cancel() @@ -566,6 +568,7 @@ func (node *DataNode) Stop() error { return nil } +// GetTimeTickChannel currently do nothing func (node *DataNode) GetTimeTickChannel(ctx context.Context) (*milvuspb.StringResponse, error) { return &milvuspb.StringResponse{ Status: &commonpb.Status{ @@ -576,6 +579,7 @@ func (node *DataNode) GetTimeTickChannel(ctx context.Context) (*milvuspb.StringR }, nil } +// GetStatisticsChannel currently do nothing func (node *DataNode) GetStatisticsChannel(ctx context.Context) (*milvuspb.StringResponse, error) { return &milvuspb.StringResponse{ Status: &commonpb.Status{