From c782a05c2fdcfa8780e6dda848cf21dd582a7e98 Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Thu, 11 Nov 2021 22:13:05 +0800 Subject: [PATCH] [skip ci] Add comment for getCollectionFlowGraphs (#11688) Signed-off-by: bigsheeper --- internal/querynode/data_sync_service.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/querynode/data_sync_service.go b/internal/querynode/data_sync_service.go index b587a9b427..dae74d00f9 100644 --- a/internal/querynode/data_sync_service.go +++ b/internal/querynode/data_sync_service.go @@ -100,6 +100,7 @@ func (dsService *dataSyncService) addCollectionDeltaFlowGraph(collectionID Uniqu } } +// getCollectionFlowGraphs returns the collection flowGraph by collectionID func (dsService *dataSyncService) getCollectionFlowGraphs(collectionID UniqueID, vChannels []string) (map[Channel]*queryNodeFlowGraph, error) { dsService.mu.Lock() defer dsService.mu.Unlock()