Add comment for datacoord Server.startDataNodeTtLoop (#11033)

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
pull/11354/head
congqixia 2021-11-05 23:01:02 +08:00 committed by GitHub
parent 3ac7d7a9de
commit 0c4e09e341
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 0 deletions

View File

@ -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 {