module Concussion
This adapter uses a Redis hash, as providing a list of normal keys matching a pattern is problematic. We manage key/value expiration outside Redis, to avoid jobs disappearing while the server is inactive.
Constants
- VERSION
Attributes
store[RW]
Public Class Methods
init()
click to toggle source
# File lib/concussion.rb, line 19 def self.init store.find_each do |guid, data| retire guid Object.const_get(data[:klass]).new.later data[:time], *(data[:args]) end end
persist(klass, guid, time, *args)
click to toggle source
# File lib/concussion.rb, line 11 def self.persist(klass, guid, time, *args) store.set guid, {klass: klass.name, time: time, args: args} end
retire(guid)
click to toggle source
# File lib/concussion.rb, line 15 def self.retire(guid) store.del guid end