milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Rename newExpiredCleanUp to expiredCleanUp (#11433) 

Signed-off-by: fishpenguin <kun.yu@zilliz.com>
pull/11449/head
yukun 2021-11-08 19:25:00 +08:00 committed by GitHub
parent 27eeb53703
commit dfbb4c33b4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/util/rocksmq/server/rocksmq/rocksmq_retention.go
View File

@ -134,7 +134,7 @@ func (ri *retentionInfo) retention() error {
return true
}
if lastRetentionTs+checkTime < timeNow {
err := ri.newExpiredCleanUp(topic)
err := ri.expiredCleanUp(topic)
if err != nil {
log.Warn("Retention expired clean failed", zap.Any("error", err))
}
@ -159,7 +159,7 @@ func (ri *retentionInfo) Stop() {
// 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 {
func (ri *retentionInfo) expiredCleanUp(topic string) error {
log.Debug("Timeticker triggers an expiredCleanUp task for topic: " + topic)
var deletedAckedSize int64 = 0
var startID UniqueID