From f15dc150f1bfdb298831da4dc261d91c30295b35 Mon Sep 17 00:00:00 2001 From: yukun Date: Thu, 21 Oct 2021 10:59:01 +0800 Subject: [PATCH] [skip ci]Add comments for retention (#10316) Signed-off-by: fishpenguin --- internal/util/rocksmq/server/rocksmq/rocksmq_retention.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go b/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go index fbd9404db5..42e428110c 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go @@ -274,6 +274,7 @@ func (ri *retentionInfo) loadRetentionInfo(topic string, wg *sync.WaitGroup) { ri.lastRetentionTime.Store(topic, lastRetentionTs) } +// retention do time ticker and trigger retention check and operation for each topic func (ri *retentionInfo) retention() error { log.Debug("Rocksmq retention goroutine start!") // Do retention check every 6s