Module: ActiveJob::Status::Storage

Defined in:
lib/activejob-status/storage.rb

Class Method Summary collapse

Class Method Details

.delete(job) ⇒ Object 



28
29
30
 
# File 'lib/activejob-status/storage.rb', line 28

def delete(job)
  store.delete(key(job))
end

.job_id(job) ⇒ Object 



8
9
10
 
# File 'lib/activejob-status/storage.rb', line 8

def job_id(job)
  job.is_a?(String) ? job : job.job_id
end

.key(job) ⇒ Object 



12
13
14
 
# File 'lib/activejob-status/storage.rb', line 12

def key(job)
  "activejob:status:#{job_id(job)}"
end

.read(job) ⇒ Object 



16
17
18
 
# File 'lib/activejob-status/storage.rb', line 16

def read(job)
  store.read(key(job)) || {}
end

.store ⇒ Object 



4
5
6
 
# File 'lib/activejob-status/storage.rb', line 4

def store
  ActiveJob::Status.store
end

.update(job, message) ⇒ Object 



24
25
26
 
# File 'lib/activejob-status/storage.rb', line 24

def update(job, message)
  write(job, read(job).merge(message))
end

.write(job, message) ⇒ Object 



20
21
22
 
# File 'lib/activejob-status/storage.rb', line 20

def write(job, message)
  store.write(key(job), message, expires_in: DEFAULT_EXPIRY)
end