Module: ActiveJob::Status::Storage

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

Class Method Summary collapse

Class Method Details

.delete(job) ⇒ Object 



33
34
35
 
# File 'lib/activejob-status/storage.rb', line 33

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

.job_id(job) ⇒ Object 



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

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

.key(job) ⇒ Object 



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

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

.options ⇒ Object 



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

def options
  ActiveJob::Status.options
end

.read(job) ⇒ Object 



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

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

.store ⇒ Object 



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

def store
  ActiveJob::Status.store
end

.update(job, message) ⇒ Object 



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

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

.write(job, message) ⇒ Object 



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

def write(job, message)
  store.write(key(job), message, expires_in: options[:expires_in])
end