From ff5599e7a25cd66a0db989885a6049dd07f28fae Mon Sep 17 00:00:00 2001 From: Pablo Ubal Naveira Date: Thu, 26 Sep 2024 13:11:09 +0200 Subject: [PATCH] adjust reset_ms based on fixed_window --- lib/take.lua | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/lib/take.lua b/lib/take.lua index 7856aa3..29b8ab4 100644 --- a/lib/take.lua +++ b/lib/take.lua @@ -49,7 +49,9 @@ redis.call('HMSET', KEYS[1], redis.call('EXPIRE', KEYS[1], ttl) local reset_ms = 0 -if drip_interval > 0 then +if fixed_window > 0 then + reset_ms = current_timestamp_ms + fixed_window +elseif drip_interval > 0 then reset_ms = math.ceil(current_timestamp_ms + (bucket_size - new_content) * drip_interval) end