mirror of https://github.com/milvus-io/milvus.git
[skip ci]Add comments for retention (#10316)
Signed-off-by: fishpenguin <kun.yu@zilliz.com>pull/10344/head
parent
c2fa2e940d
commit
f15dc150f1
|
@ -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
|
||||
|
|
Loading…
Reference in New Issue