diff options
| author | alexbogo <[email protected]> | 2023-04-20 16:33:45 +0300 |
|---|---|---|
| committer | alexbogo <[email protected]> | 2023-04-20 16:33:45 +0300 |
| commit | 2443476d1388a3c3054dbd8adb4a8b04a8494abe (patch) | |
| tree | 9a7729663e07d0470cb047b3e1e536259f9b488d /library/cpp/messagebus/messqueue.cpp | |
| parent | bacb095f225d39abedab523aa4ffef7fb8492d3d (diff) | |
[ymq] smart planning of deleting messages by retention
1) когда форсим обновление стета лидера HandleForceReloadState (подозрение на второго лидера ), запрашиваем обновить значение аттрибутов о котрых знает лидер (важно держать актуальным RetentionPeriod)
2) далее по wakeup внутри лидера смотрим когда запланировать следующее удаление данных в очереди PlanningRetentionWakeup и при необходимости планируем отправку сообщения Wakeup в RetentionActor, который как раз инициирует удаление данных по сроку давности
3) при уменьшении RetentionPeriod аттрибута (даже потенциальном) сбрасываем информациб о том когда запланировано ближайшее удаление по retention
Diffstat (limited to 'library/cpp/messagebus/messqueue.cpp')
0 files changed, 0 insertions, 0 deletions