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