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