Class: Rjob::Scripts::EnqueueJob

Inherits:
RedisScript show all
Defined in:
lib/rjob/scripts/enqueue_job.rb

Instance Attribute Summary

Attributes inherited from RedisScript

#sha1

Instance Method Summary collapse

Methods inherited from RedisScript

#key_params

Instance Method Details

#arg_params ⇒ Object 



4
5
6
 
# File 'lib/rjob/scripts/enqueue_job.rb', line 4

def arg_params
  %i(prefix bucket_count job_data)
end

#lua_script ⇒ Object 



8
9
10
11
12
13
14
15
16
17
18
19
20
 
# File 'lib/rjob/scripts/enqueue_job.rb', line 8

def lua_script
  <<~LUA
    local prefix = ARGV[1]
    local bucket_count = tonumber(ARGV[2])
    local job_data = ARGV[3]
    local r = redis
    local job_id = r.call('incr', prefix .. ':next')
    local bucket = job_id % bucket_count
    r.call('lpush', prefix .. ':jobs:' .. bucket, job_id .. '!0!' .. job_data)
    r.call('publish', prefix .. ':jobs', tostring(bucket))
    return job_id
  LUA
end