242
func CleanupRuleTombstones(versioningData *persistencespb.VersioningData,
243
retentionTime time.Duration,
245
>
modifiedData := shallowCloneVersioningData(versioningData)
246
>
modifiedData.AssignmentRules = util.FilterSlice(modifiedData.GetAssignmentRules(), func(ar *persistencespb.AssignmentRule) bool {
247
return ar.DeleteTimestamp == nil || (ar.DeleteTimestamp != nil && hlc.Since(ar.DeleteTimestamp) < retentionTime)
248
})
249
>
modifiedData.RedirectRules = util.FilterSlice(modifiedData.GetRedirectRules(), func(rr *persistencespb.RedirectRule) bool {
version_rule_helpers.go
250
>
return rr.DeleteTimestamp == nil || (rr.DeleteTimestamp != nil && hlc.Since(rr.DeleteTimestamp) < retentionTime)
251
>
})
252
>
return modifiedData
253
}
254