[skip ci]Add comments for rocksmq SeekToLatest (#10120)

Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-18 19:52:49 +08:00 · 2021-10-18 19:52:49 +08:00 · 401753dea0
parent ec667846f4
commit 401753dea0
1 changed files with 1 additions and 0 deletions
--- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
+++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go
@ -704,6 +704,7 @@ func (rmq *rocksmq) Seek(topicName string, groupName string, msgID UniqueID) err
 	return nil
 }

+// SeekToLatest updates current id to the msg id of latest message
 func (rmq *rocksmq) SeekToLatest(topicName, groupName string) error {
 	rmq.storeMu.Lock()
 	defer rmq.storeMu.Unlock()