From ee2027be87a0c6855b29f85e8e99f1154b347b81 Mon Sep 17 00:00:00 2001 From: yukun Date: Thu, 23 Dec 2021 17:05:13 +0800 Subject: [PATCH] [skip e2e]Add comment for rmq reader (#13624) Signed-off-by: fishpenguin --- internal/util/mqclient/rmq_reader.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/mqclient/rmq_reader.go b/internal/util/mqclient/rmq_reader.go index 11a478fc2b..eb4859535c 100644 --- a/internal/util/mqclient/rmq_reader.go +++ b/internal/util/mqclient/rmq_reader.go @@ -32,6 +32,7 @@ func (rr *rmqReader) HasNext() bool { return rr.r.HasNext() } +// Seek seeks the reader position to id func (rr *rmqReader) Seek(id MessageID) error { msgID := id.(*rmqID).messageID return rr.r.Seek(msgID)