From a1ab961e49144e45190a8c4a4cd44498e71fc01d Mon Sep 17 00:00:00 2001 From: yukun Date: Fri, 3 Dec 2021 20:31:54 +0800 Subject: [PATCH] [skip ci]Add comment for rocksmq reader (#12730) Signed-off-by: fishpenguin --- internal/util/rocksmq/server/rocksmq/rocksmq_reader.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_reader.go b/internal/util/rocksmq/server/rocksmq/rocksmq_reader.go index f42bdbf5b..73c17b875 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_reader.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_reader.go @@ -35,6 +35,7 @@ type rocksmqReader struct { readerMutex chan struct{} } +//Seek seek the rocksmq reader to the pointed position func (rr *rocksmqReader) Seek(msgID UniqueID) { //nolint:govet rr.currentID = msgID select { -- GitLab