module ActiveJob::Status::Storage
Public Class Methods
delete(job)
click to toggle source
# File lib/activejob-status/storage.rb, line 33 def delete(job) store.delete(key(job)) end
job_id(job)
click to toggle source
# File lib/activejob-status/storage.rb, line 13 def job_id(job) job.is_a?(String) ? job : job.job_id end
key(job)
click to toggle source
# File lib/activejob-status/storage.rb, line 17 def key(job) "activejob:status:#{job_id(job)}" end
options()
click to toggle source
# File lib/activejob-status/storage.rb, line 9 def options ActiveJob::Status.options end
read(job)
click to toggle source
# File lib/activejob-status/storage.rb, line 21 def read(job) store.read(key(job)) || {} end
store()
click to toggle source
# File lib/activejob-status/storage.rb, line 5 def store ActiveJob::Status.store end
update(job, message)
click to toggle source
# File lib/activejob-status/storage.rb, line 29 def update(job, message) write(job, read(job).merge(message)) end
write(job, message)
click to toggle source
# File lib/activejob-status/storage.rb, line 25 def write(job, message) store.write(key(job), message, expires_in: options[:expires_in]) end