From 0c4e09e341f0bdb4b7558b4c332aaa8c27f9200c Mon Sep 17 00:00:00 2001
From: congqixia <congqi.xia@zilliz.com>
Date: Fri, 5 Nov 2021 23:01:02 +0800
Subject: [PATCH] Add comment for datacoord Server.startDataNodeTtLoop (#11033)

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
---
 internal/datacoord/server.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/internal/datacoord/server.go b/internal/datacoord/server.go
index 45358f2244..f0f34142cd 100644
--- a/internal/datacoord/server.go
+++ b/internal/datacoord/server.go
@@ -388,6 +388,8 @@ func (s *Server) startStatsChannel(ctx context.Context) {
 	}()
 }
 
+// startDataNodeTtLoop start a goroutine to recv data node tt msg from msgstream
+// tt msg stands for the currently consumed timestamp for each channel
 func (s *Server) startDataNodeTtLoop(ctx context.Context) {
 	ttMsgStream, err := s.msFactory.NewMsgStream(ctx)
 	if err != nil {