DS
Size: a a a
DS
MA
DS
local LOG_EXPIRATION_PERIOD = 24 * 60 * 60 -- 24 hours.
local EXPIRATIOND_TUPLES_PER_ITERATION = 10000
local EXPIRATIOND_FULL_SCAN_TIME = 10800 -- 3 hours.
local function brutal_slog_is_log_expired(args, tuple)
local now = os.time()
return (now - tuple[BRUTAL_TS]) >= LOG_EXPIRATION_PERIOD
end
local function brutal_slog_remove_expired(space_id, args, tuple)
box.space.brutal_slog:delete({ tuple[BRUTAL_ID] })
end
expirationd.start('expirationd_brutal_slog', box.space.brutal_slog.id, brutal_slog_is_log_expired, {
process_expired_tuple = brutal_slog_remove_expired,
args = {},
tuples_per_iteration = EXPIRATIOND_TUPLES_PER_ITERATION,
full_scan_time = EXPIRATIOND_FULL_SCAN_TIME,
force = true,
})
expirationd.task('expirationd_brutal_slog'):start()
, то отрабатывает нормально.PP
dofile('/etc/tarantool/instances.enabled/sliding_log.lua')
PP
expirationd.task('expirationd_brutal_slog'):statistics()
---
- expired_count: 4992899
working_time: 79710
restarts: 3
checked_count: 13050839
...
PP
AL
MO
PL
AL
MO
MO
MF
MO
D
DS
DS
3
3