未验证 提交 a1ab961e 编写于 作者: Y yukun 提交者: GitHub

[skip ci]Add comment for rocksmq reader (#12730)

Signed-off-by: Nfishpenguin <kun.yu@zilliz.com>
上级 3ef67c04
...@@ -35,6 +35,7 @@ type rocksmqReader struct { ...@@ -35,6 +35,7 @@ type rocksmqReader struct {
readerMutex chan struct{} readerMutex chan struct{}
} }
//Seek seek the rocksmq reader to the pointed position
func (rr *rocksmqReader) Seek(msgID UniqueID) { //nolint:govet func (rr *rocksmqReader) Seek(msgID UniqueID) { //nolint:govet
rr.currentID = msgID rr.currentID = msgID
select { select {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册