From a5a85f75bd1a4d43cc6ec65227f70981e5658e34 Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Fri, 1 Oct 2021 09:53:43 +0800 Subject: [PATCH] [skip ci] Add comment for newDataSyncService (#8962) 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 de0a21d921..9168abd909 100644 --- a/internal/querynode/data_sync_service.go +++ b/internal/querynode/data_sync_service.go @@ -195,6 +195,7 @@ func (dsService *dataSyncService) removePartitionFlowGraph(partitionID UniqueID) delete(dsService.partitionFlowGraphs, partitionID) } +// newDataSyncService returns a new dataSyncService func newDataSyncService(ctx context.Context, streamingReplica ReplicaInterface, tSafeReplica TSafeReplicaInterface,