[skip ci]Add comments for rocksmq DestroyTopic (#9735)

Signed-off-by: fishpenguin <kun.yu@zilliz.com>
2021-10-12 19:37:20 +08:00 · 2021-10-12 19:37:20 +08:00 · e3ce1696e7
parent d5e179e70b
commit e3ce1696e7
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
@ -283,6 +283,7 @@ func (rmq *rocksmq) CreateTopic(topicName string) error {
 	return nil
 }

+// DestroyTopic removes messages for topic in rocksdb
 func (rmq *rocksmq) DestroyTopic(topicName string) error {
 	start := time.Now()
 	beginKey := topicName + "/begin_id"