apalis-redis 1.0.0

Background task processing for rust using apalis and redis
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

-- KEYS[1]: the active workers sorted set
--
-- ARGV[1]: current time
-- ARGV[2]: worker name
local now = tonumber(ARGV[1])
local worker = ARGV[2]

local last_seen = redis.call("zscore", KEYS[1], worker)

-- Worker is not registered
if not last_seen then
    error("Heartbeat failed: worker not registered")
end

-- Update the worker's heartbeat
redis.call("zadd", KEYS[1], now, worker)

return true