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

[skip ci]Add retention comment (#11432)

Signed-off-by: Nfishpenguin <kun.yu@zilliz.com>
上级 e8fc0bed
......@@ -154,6 +154,11 @@ func (ri *retentionInfo) Stop() {
})
}
// expiredCleanUp check message retention by page:
// 1. check acked timestamp of each page id, if expired, the whole page is expired;
// 2. check acked size from the last unexpired page id;
// 3. delete acked info by range of page id;
// 4. delete message by range of page id;
func (ri *retentionInfo) newExpiredCleanUp(topic string) error {
log.Debug("Timeticker triggers an expiredCleanUp task for topic: " + topic)
var deletedAckedSize int64 = 0
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册