### global
[vars]
var qname = "foo"
### job request
var data = "bar"
var id = (redis) INCR /job/${qname}/ids/max
(redis) HSET /job/${qname}/datas ${id} ${data}
(redis) LPUSH /job/${qname}/ids ${id}
### job workers
[dequeue]
var id = (redis) RPOPLPUSH /job/${qname}/ids /job/${qname}/ids
var data = (redis) HGET /job/${qname}/datas ${id}
(redis) HSET /job/${qname}/locks ${id} ${expiry}
[execute]
(redis) SADD /job/${qname}/done ${id}
Last active
February 8, 2022 14:41
-
-
Save maiha/46a6d980c5c6d2fa9b419c168168353d to your computer and use it in GitHub Desktop.
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment