From b261e89a92ddcf0e345263b30dabf90849f60afa Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Thu, 11 Nov 2021 22:14:57 +0800 Subject: [PATCH] [skip ci] Add comment for getCollectionDeltaFlowGraphs (#11689) 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 dae74d00f9..47aa6d95f9 100644 --- a/internal/querynode/data_sync_service.go +++ b/internal/querynode/data_sync_service.go @@ -119,6 +119,7 @@ func (dsService *dataSyncService) getCollectionFlowGraphs(collectionID UniqueID, return tmpFGs, nil } +// getCollectionDeltaFlowGraphs returns the collection delta flowGraph by collectionID func (dsService *dataSyncService) getCollectionDeltaFlowGraphs(collectionID UniqueID, vChannels []string) (map[Channel]*queryNodeFlowGraph, error) { dsService.mu.Lock() defer dsService.mu.Unlock()