redistaskmgr

var (
	QPUSH = redis.NewScript(1, `
local keySet = KEYS[1] .. '::set'
local keyQueue = KEYS[1] .. '::queue'
local id = ARGV[1]
local data = ARGV[2]
local success = redis.call('HSETNX', keySet, id, data)

if (success == 1) then 
	redis.call('RPUSH', keyQueue, id)
end
`)

	QSHIFT = redis.NewScript(1, `
local keySet = KEYS[1] .. '::set'
local keyQueue = KEYS[1] .. '::queue'
local id = redis.call('LPOP', keyQueue)
local data

if (id == nil or id == false) then
	return id
end

data = redis.call('HGET', keySet, id)
redis.call('HDEL', keySet, id)
return data
`)

	QDEL = redis.NewScript(1, `
local keySet = KEYS[1] .. '::set'
local keyQueue = KEYS[1] .. '::queue'

redis.call('DEL', keySet)
redis.call('DEL', keyQueue)
`)

	QREM = redis.NewScript(1, `
local keySet = KEYS[1] .. '::set'
local id = ARGV[1]

redis.call('HDEL', keySet, id)
`)
)