rsmq_async 18.0.0

Async RSMQ port to rust. RSMQ is a simple redis queue system that works in any redis v2.4+. It contains the same methods as the original one in https://github.com/smrchy/rsmq
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

-- Atomically inserts a batch of messages into the queue.
-- KEYS[1]: namespace:queuename (the sorted set key for the queue)
-- ARGV[1]: realtime flag ("1" or "0") — when "1", returns the new ZCARD so the
--          caller can do a single PUBLISH outside the script.
-- ARGV[2..]: triplets of (id, score, body), one per message. Total length must be
--            1 + 3*N for N messages.
-- Returns: new ZCARD if realtime, else 0.

local n = (#ARGV - 1) / 3
local queue_hash = KEYS[1] .. ":Q"

for i = 0, n - 1 do
    local id    = ARGV[2 + i * 3]
    local score = ARGV[3 + i * 3]
    local body  = ARGV[4 + i * 3]
    redis.call("ZADD", KEYS[1], score, id)
    redis.call("HSET", queue_hash, id, body)
end

redis.call("HINCRBY", queue_hash, "totalsent", n)

if ARGV[1] == "1" then
    return redis.call("ZCARD", KEYS[1])
end
return 0